Skip to content

Commit 2fd58f6

Browse files
committed
added event for computational status update
1 parent ca8acae commit 2fd58f6

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

packages/models-library/src/models_library/rabbitmq_messages.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -316,3 +316,13 @@ class WalletCreditsLimitReachedMessage(RabbitMessageBase):
316316

317317
def routing_key(self) -> str | None:
318318
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

Comments
 (0)