cata_log_hub.scheduler module

cata_log_hub.scheduler.retry_on_network_error_listener(event)[source]

Listener for job errors that schedules a retry job on networkerror.

Args: event: The jobevent.

Return type:

None

Parameters:

event (JobExecutionEvent)

cata_log_hub.scheduler.run_scheduler(app)[source]

Controls the scheduler.

Return type:

AsyncGenerator[None]

Parameters:

app (FastAPI)