FilesExpand file tree

main

/

lambda_function.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

19 lines (14 loc) · 661 Bytes

main

/

lambda_function.py

Copy path

Top

File metadata and controls

• Code
• Blame

19 lines (14 loc) · 661 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

from temporalio.common import WorkerDeploymentVersion

from temporalio.contrib.aws.lambda_worker import LambdaWorkerConfig, run_worker

from temporalio.contrib.aws.lambda_worker.otel import apply_defaults

from activities import hello_activity

from workflows import TASK_QUEUE, SampleWorkflow

def configure(config: LambdaWorkerConfig) -> None:

config.worker_config["task_queue"] = TASK_QUEUE

config.worker_config["workflows"] = [SampleWorkflow]

config.worker_config["activities"] = [hello_activity]

apply_defaults(config)

lambda_handler = run_worker(

WorkerDeploymentVersion(deployment_name="my-app", build_id="build-1"),

configure,

)