dagster_docker_executor_quickstart_with_container_steps.py

1from dagster import job, op, repository
2from dagster_docker import docker_executor
3
4@op
5def hello_docker():
6    return "Hello from a Docker container!"
7
8@job(executor_def=docker_executor)
9def docker_job():
10    hello_docker()
11
12@repository
13def my_repository():
14    return [docker_job]
15
16# To run this job, the Dagster instance must be configured with a 
17# DockerRunLauncher in the dagster.yaml file:
18#
19# run_launcher:
20#   module: dagster_docker
21#   class: DockerRunLauncher
22#   config:
23#     networks:
24#       - dagster_network