Skip to content

Commit 157bbac

Browse files
committed
fixes to make services functional again
1 parent 6c10aed commit 157bbac

File tree

6 files changed

+5
-4
lines changed

6 files changed

+5
-4
lines changed

β€Žservices/api-server/src/simcore_service_api_server/api/routes/functions_routes.pyβ€Ž

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727

2828
from ..._service_function_jobs import FunctionJobService
2929
from ..._service_functions import FunctionService
30-
from ...celery._worker_tasks._functions_tasks import run_function
30+
from ...celery.worker_tasks.functions_tasks import run_function as run_function_task
3131
from ...models.pagination import Page, PaginationParams
3232
from ...models.schemas.errors import ErrorGet
3333
from ...models.schemas.jobs import JobPricingSpecification
@@ -351,7 +351,7 @@ async def run_function( # noqa: PLR0913
351351
client_name=ASYNC_JOB_CLIENT_NAME,
352352
)
353353
task_filter = TaskFilter.model_validate(job_filter.model_dump())
354-
task_name = run_function.__name__
354+
task_name = run_function_task.__name__
355355

356356
task_uuid = await task_manager.submit_task(
357357
TaskMetadata(

β€Žservices/api-server/src/simcore_service_api_server/celery/worker_main.pyβ€Ž

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313

1414
from ..core.application import create_app
1515
from ..core.settings import ApplicationSettings
16-
from ._worker_tasks.tasks import setup_worker_tasks
16+
from .worker_tasks.tasks import setup_worker_tasks
1717

1818

1919
def app_factory():

β€Žservices/api-server/src/simcore_service_api_server/celery/worker_tasks/__init__.pyβ€Ž

Whitespace-only changes.
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
from ...api.dependencies.authentication import Identity
1414
from ...models.api_resources import JobLinks
1515
from ...models.schemas.jobs import JobPricingSpecification
16-
from ._functions_tasks import run_function
16+
from .functions_tasks import run_function
1717

1818
_logger = logging.getLogger(__name__)
1919

β€Žservices/docker-compose.ymlβ€Ž

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ services:
3232
API_SERVER_LOG_FILTER_MAPPING: ${LOG_FILTER_MAPPING}
3333
API_SERVER_LOGLEVEL: ${API_SERVER_LOGLEVEL}
3434
API_SERVER_PROFILING: ${API_SERVER_PROFILING}
35+
API_SERVER_WORKER_MODE: "false"
3536

3637
CATALOG_HOST: ${CATALOG_HOST}
3738
CATALOG_PORT: ${CATALOG_PORT}

0 commit comments

Comments
Β (0)