Merge pull request #31 from BNLNPPS/infra/baseline-v30

wenaus · web-flow · commit 4aa31f1fd0f5 · 2026-02-03T09:52:03.000-05:00
Release v30: Message type standardization
diff --git a/src/swf_common_lib/base_agent.py b/src/swf_common_lib/base_agent.py
@@ -117,7 +117,7 @@ class BaseAgent(stomp.ConnectionListener):
     # Standard workflow message types
     WORKFLOW_MESSAGE_TYPES = {
         'run_imminent', 'start_run', 'pause_run', 'resume_run', 'end_run',
-        'stf_gen', 'data_ready'
+        'stf_gen', 'stf_ready', 'tf_file_registered'
     }
 
     def __init__(self, agent_type, subscription_queue, debug=False,

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@ class BaseAgent(stomp.ConnectionListener):`
`117`	`117`	`# Standard workflow message types`
`118`	`118`	`WORKFLOW_MESSAGE_TYPES = {`
`119`	`119`	`'run_imminent', 'start_run', 'pause_run', 'resume_run', 'end_run',`
`120`		`- 'stf_gen', 'data_ready'`
	`120`	`+ 'stf_gen', 'stf_ready', 'tf_file_registered'`
`121`	`121`	`}`
`122`	`122`
`123`	`123`	`def __init__(self, agent_type, subscription_queue, debug=False,`