File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 1111# limitations under the License.
1212import asyncio
1313from datetime import timedelta
14- from time import sleep
1514
1615from dapr .ext .workflow import (
1716 DaprWorkflowContext ,
@@ -143,11 +142,13 @@ async def main():
143142
144143 # Resume Test
145144 await wf_client .resume_workflow (instance_id = instance_id )
146- metadata = await wf_client .get_workflow_state (instance_id = instance_id )
145+ metadata = await wf_client .get_workflow_state (instance_id = instance_id )
147146 print (f'Get response from { workflow_name } after resume call: { metadata .runtime_status .name } ' )
148147
149148 await asyncio .sleep (2 ) # Give the workflow time to reach the event wait state
150- await wf_client .raise_workflow_event (instance_id = instance_id , event_name = event_name , data = event_data )
149+ await wf_client .raise_workflow_event (
150+ instance_id = instance_id , event_name = event_name , data = event_data
151+ )
151152
152153 print ('========= Waiting for Workflow completion' , flush = True )
153154 try :
You can’t perform that action at this time.
0 commit comments