example_airflow.py

# example_airflow.py
from dagster import lambda_solid, pipeline

@lambda_solid
def hello_world():
    return "hello, world"

@pipeline
def basic_pipeline():
    hello_world()

example_create_dag.py

'''
example_create_dag.py
The airflow DAG
'''
import os

from dagster import ExecutionTargetHandle
from dagster_airflow.factory import make_airflow_dag_for_handle

airflow_dags_path = os.path.dirname(os.path.abspath(__file__))

dag, steps = make_airflow_dag_for_handle(
    ExecutionTargetHandle.for_pipeline_python_file(
        python_file=os.path.join(airflow_dags_path, 'example_airflow.py'), fn_name='basic_pipeline'
    ),
    'basic_pipeline',
    environment_dict={'storage': {'filesystem': {}}},
)