Dagster job factory for default tags

job_factory.py

from dagster import job


def custom_job(*args, **kwargs):
    default_tags = {"foo": "bar"}
    kwargs["tags"] = {**kwargs.get("tags", {}), **default_tags}

    def inner(func):
        return (job(*args, **kwargs))(func)

    return inner


@custom_job()
def my_job():
    pass