Skip to content
tempo.insights.worker module
-
tempo.insights.worker.start_insights_worker_from_async(worker_endpoint: str, parallelism: int = 1, batch_size: int = 1, retries: int = 3, window_time: int = None) → janus._AsyncQueueProxy
-
tempo.insights.worker.start_insights_worker_from_sync(worker_endpoint: str = '', batch_size: int = 1, parallelism: int = 1, retries: int = 3, output_file_path: str = None, window_time: int = None) → janus._SyncQueueProxy
-
async
tempo.insights.worker.start_worker(q_in: janus.Queue, worker_endpoint: str, parallelism: int = 1, batch_size: int = 1, retries: int = 3, window_time: int = None)
-
tempo.insights.worker.sync_init_loop_queue(event, worker_endpoint, parallelism, batch_size, retries, window_time)