Update templates/workflow_template.py.j2
This commit is contained in:
parent
6689790c6a
commit
7f8c57bd22
@ -16,6 +16,7 @@ logger = logging.getLogger(__name__)
|
|||||||
class {{ workflow_class_name }}:
|
class {{ workflow_class_name }}:
|
||||||
@temporalio.workflow.run
|
@temporalio.workflow.run
|
||||||
async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]:
|
async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]:
|
||||||
|
await temporalio.workflow.sleep(0)
|
||||||
workflow_info = temporalio.workflow.info()
|
workflow_info = temporalio.workflow.info()
|
||||||
workflow_output: Dict[str, Any] = {
|
workflow_output: Dict[str, Any] = {
|
||||||
"workflow_id": workflow_info.workflow_id,
|
"workflow_id": workflow_info.workflow_id,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user