update

Author: kraftp

dbos/_dbos.py

@@ -1296,6 +1296,10 @@ async def list_workflow_steps_async(cls, workflow_id: str) -> List[StepInfo]:
     def application_version(cls) -> str:
         return GlobalParams.app_version
 
+    @classproperty
+    def executor_id(cls) -> str:
+        return GlobalParams.executor_id
+
     @classproperty
     def logger(cls) -> Logger:
         """Return the DBOS `Logger` for the current context."""

tests/test_dbos.py

@@ -1504,7 +1504,7 @@ def test_workflow() -> str:
 
     DBOS.launch()
     assert DBOS.application_version == app_version
-    assert GlobalParams.executor_id == executor_id
+    assert GlobalParams.executor_id == executor_id == DBOS.executor_id
     wfid = test_workflow()
     handle: WorkflowHandle[str] = DBOS.retrieve_workflow(wfid)
     assert handle.get_status().app_version == app_version