Skip to content

Commit d140987

Browse files
committed
@pcrespov review: removed warning
1 parent fe4f33b commit d140987

File tree

1 file changed

+8
-14
lines changed

1 file changed

+8
-14
lines changed

services/web/server/src/simcore_service_webserver/notifications/_rabbitmq_exclusive_queue_consumers.py

Lines changed: 8 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -102,20 +102,14 @@ async def _computational_pipeline_status_message_parser(
102102
app: web.Application, data: bytes
103103
) -> bool:
104104
rabbit_message = ComputationalPipelineStatusMessage.model_validate_json(data)
105-
try:
106-
project = await _projects_service.get_project_for_user(
107-
app,
108-
f"{rabbit_message.project_id}",
109-
rabbit_message.user_id,
110-
include_state=True,
111-
)
112-
await _projects_service.notify_project_state_update(app, project)
113-
except ProjectNotFoundError:
114-
_logger.warning(
115-
"Project %s not found for user %s",
116-
rabbit_message.project_id,
117-
rabbit_message.user_id,
118-
)
105+
project = await _projects_service.get_project_for_user(
106+
app,
107+
f"{rabbit_message.project_id}",
108+
rabbit_message.user_id,
109+
include_state=True,
110+
)
111+
await _projects_service.notify_project_state_update(app, project)
112+
119113
return True
120114

121115

0 commit comments

Comments
 (0)