We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 383c511 commit f9cc279Copy full SHA for f9cc279
packages/models-library/src/models_library/rabbitmq_messages.py
@@ -316,3 +316,13 @@ class WalletCreditsLimitReachedMessage(RabbitMessageBase):
316
317
def routing_key(self) -> str | None:
318
return f"{self.wallet_id}.{self.credits_limit}"
319
+
320
321
+class ComputationalPipelineStatusMessage(RabbitMessageBase, ProjectMessageBase):
322
+ channel_name: Literal["io.simcore.service.computation.pipeline-status"] = (
323
+ "io.simcore.service.computation.pipeline-status"
324
+ )
325
+ run_result: RunningState
326
327
+ def routing_key(self) -> str | None:
328
+ return f"{self.project_id}"
0 commit comments