FilesExpand file tree

main

/

workflows.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

22 lines (17 loc) · 703 Bytes

main

/

workflows.py

Copy path

Top

File metadata and controls

• Code
• Blame

22 lines (17 loc) · 703 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

from datetime import timedelta

from temporalio import common, workflow

TASK_QUEUE = "serverless-task-queue-python"

with workflow.unsafe.imports_passed_through():

from activities import hello_activity

@workflow.defn(versioning_behavior=common.VersioningBehavior.PINNED)

class SampleWorkflow:

@workflow.run

async def run(self, name: str) -> str:

workflow.logger.info("SampleWorkflow started with name: %s", name)

result = await workflow.execute_activity(

hello_activity,

name,

start_to_close_timeout=timedelta(seconds=10),

)

workflow.logger.info("SampleWorkflow completed with result: %s", result)

return result