EQ-SQL API Documentation

Contents:

• eqsql package
  • Submodules
    • eqsql.task_queues.core module
      • Future
        • Future.cancel()
        • Future.done()
        • Future.priority
        • Future.result()
        • Future.status
        • Future.worker_pool
      • ResultStatus
        • ResultStatus.FAILURE
        • ResultStatus.SUCCESS
      • StopConditionException
      • TaskQueue
        • TaskQueue.are_queues_empty()
        • TaskQueue.as_completed()
        • TaskQueue.cancel_tasks()
        • TaskQueue.get_priorities()
        • TaskQueue.get_status()
        • TaskQueue.get_worker_pools()
        • TaskQueue.pop_completed()
        • TaskQueue.query_result()
        • TaskQueue.submit_task()
        • TaskQueue.submit_tasks()
        • TaskQueue.update_priorities()
      • TaskStatus
        • TaskStatus.CANCELED
        • TaskStatus.COMPLETE
        • TaskStatus.QUEUED
        • TaskStatus.REQUEUED
        • TaskStatus.RUNNING
      • TimeoutError
    • eqsql.task_queues.local_queue module
      • LocalTaskQueue
        • LocalTaskQueue.are_queues_empty()
        • LocalTaskQueue.as_completed()
        • LocalTaskQueue.cancel_tasks()
        • LocalTaskQueue.clear_queues()
        • LocalTaskQueue.close()
        • LocalTaskQueue.get_priorities()
        • LocalTaskQueue.get_status()
        • LocalTaskQueue.get_worker_pools()
        • LocalTaskQueue.pop_completed()
        • LocalTaskQueue.pop_in_queue()
        • LocalTaskQueue.pop_out_queue()
        • LocalTaskQueue.push_in_queue()
        • LocalTaskQueue.push_out_queue()
        • LocalTaskQueue.query_more_tasks()
        • LocalTaskQueue.query_result()
        • LocalTaskQueue.query_task()
        • LocalTaskQueue.report_task()
        • LocalTaskQueue.select_task_payload()
        • LocalTaskQueue.select_task_result()
        • LocalTaskQueue.stop_worker_pool()
        • LocalTaskQueue.submit_task()
        • LocalTaskQueue.submit_tasks()
        • LocalTaskQueue.update_priorities()
        • LocalTaskQueue.update_task()
      • init_task_queue()
      • random()
    • eqsql.task_queues.gc_queue module
      • GCTaskQueue
        • GCTaskQueue.are_queues_empty()
        • GCTaskQueue.as_completed()
        • GCTaskQueue.cancel_tasks()
        • GCTaskQueue.clear_queues()
        • GCTaskQueue.close()
        • GCTaskQueue.get_priorities()
        • GCTaskQueue.get_status()
        • GCTaskQueue.get_worker_pools()
        • GCTaskQueue.pop_completed()
        • GCTaskQueue.query_result()
        • GCTaskQueue.submit_task()
        • GCTaskQueue.submit_tasks()
        • GCTaskQueue.update_priorities()
      • init_task_queue()
    • eqsql.task_queues.service_queue module
      • ServiceTaskQueue
        • ServiceTaskQueue.are_queues_empty()
        • ServiceTaskQueue.as_completed()
        • ServiceTaskQueue.cancel_tasks()
        • ServiceTaskQueue.get_priorities()
        • ServiceTaskQueue.get_status()
        • ServiceTaskQueue.get_worker_pools()
        • ServiceTaskQueue.pop_completed()
        • ServiceTaskQueue.query_result()
        • ServiceTaskQueue.submit_task()
        • ServiceTaskQueue.submit_tasks()
        • ServiceTaskQueue.update_priorities()
      • init_task_queue()
    • eqsql.task_queues.emews_service module
    • eqsql.db_tools module
      • init_eqsql_db()
      • reset_db()
      • start_db()
      • stop_db()
    • eqsql.proxies module
      • app()
      • dump_proxies()
      • init()
      • load_proxies()
    • eqsql.worker_pool module
      • LocalPool
        • LocalPool.cancel()
        • LocalPool.status()
      • ScheduledPool
        • ScheduledPool.cancel()
        • ScheduledPool.status()
      • cfg_file_to_dict()
      • cfg_tofile()
      • format_pool_exp_id()
      • start_local_pool()
      • start_scheduled_pool()

Indices and tables

• Index

• Module Index

• Search Page