Skip to content

Commit f5a8f1b

Browse files
author
Andrei Neagu
committed
fixed interface
1 parent 119b892 commit f5a8f1b

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

services/web/server/src/simcore_service_webserver/long_running_tasks.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
from servicelib.long_running_tasks.models import RabbitNamespace
1414
from servicelib.long_running_tasks.task import RedisNamespace
1515

16-
from . import rabbitmq, redis
16+
from . import rabbitmq_settings, redis
1717
from ._meta import API_VTAG
1818
from .login.decorators import login_required
1919
from .models import AuthenticatedRequestContext
@@ -43,7 +43,7 @@ def setup_long_running_tasks(app: web.Application) -> None:
4343
setup(
4444
app,
4545
redis_settings=redis.get_plugin_settings(app),
46-
rabbit_settings=rabbitmq.get_plugin_settings(app),
46+
rabbit_settings=rabbitmq_settings.get_plugin_settings(app),
4747
redis_namespace=_LRT_REDIS_NAMESPACE,
4848
rabbit_namespace=_LRT_RABBIT_NAMESPACE,
4949
router_prefix=f"/{API_VTAG}/tasks-legacy",

services/web/server/src/simcore_service_webserver/tasks/_rest.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@
5959
async def get_async_jobs(request: web.Request) -> web.Response:
6060
inprocess_long_running_manager = get_long_running_manager(request.app)
6161
inprocess_tracked_tasks = await lrt_api.list_tasks(
62+
inprocess_long_running_manager.rpc_client,
6263
inprocess_long_running_manager,
6364
inprocess_long_running_manager.get_task_context(request),
6465
)

0 commit comments

Comments
 (0)