Skip to content

Commit 3c502d2

Browse files
Apply suggestion from code review
Co-authored-by: Lin Zhihao <[email protected]>
1 parent 01c60a2 commit 3c502d2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

components/job-orchestration/job_orchestration/scheduler/compress/compression_scheduler.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -520,6 +520,7 @@ def main(argv):
520520
logger.info(f"Starting {COMPRESSION_SCHEDULER_COMPONENT_NAME}")
521521
sql_adapter = SqlAdapter(clp_config.database)
522522

523+
task_manager: CeleryTaskManager | SpiderTaskManager
523524
if clp_config.compression_scheduler.type == OrchestrationType.celery:
524525
task_manager = CeleryTaskManager()
525526
elif clp_config.compression_scheduler.type == OrchestrationType.spider:

0 commit comments

Comments
 (0)