import os

from dagster import Field, ModeDefinition, String, execute_pipeline, pipeline, resource, solid


@resource(config_field=Field(String))
def env_resource(init_context):
    return os.getenv(init_context.resource_config)


@solid(required_resource_keys={'dagster_home'})
def log_dagster_home(context):
    <http://context.log.info|context.log.info>(context.resources.dagster_home)


@pipeline(
    mode_defs=[ModeDefinition(resource_defs={'dagster_home': env_resource})]
)
def dagster_home_pipeline():
    log_dagster_home()


if __name__ == '__main__':
    execute_pipeline(
        dagster_home_pipeline, {'resources': {'dagster_home': {'config': 'DAGSTER_HOME'}}}
    )