File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
services/api-server/src/simcore_service_api_server Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 77from servicelib .celery .task_manager import TaskManager
88from settings_library .celery import CelerySettings
99
10- from ...celery .worker_tasks .tasks import registered_pydantic_types
10+ from ...celery .worker_tasks .tasks import pydantic_types_to_register
1111
1212ASYNC_JOB_CLIENT_NAME : Final [str ] = "API_SERVER"
1313
@@ -19,7 +19,7 @@ async def on_startup() -> None:
1919 )
2020
2121 register_celery_types ()
22- register_pydantic_types (* registered_pydantic_types )
22+ register_pydantic_types (* pydantic_types_to_register )
2323
2424 app .add_event_handler ("startup" , on_startup )
2525
Original file line number Diff line number Diff line change 1919
2020_logger = logging .getLogger (__name__ )
2121
22- registered_pydantic_types = (
22+ pydantic_types_to_register = (
2323 Identity ,
2424 JobLinks ,
2525 JobPricingSpecification ,
3434
3535def setup_worker_tasks (app : Celery ) -> None :
3636 register_celery_types ()
37- register_pydantic_types (* registered_pydantic_types )
37+ register_pydantic_types (* pydantic_types_to_register )
3838
3939 with log_context (_logger , logging .INFO , msg = "worker task registration" ):
4040 register_task (app , run_function )
You can’t perform that action at this time.
0 commit comments