johannkm

from dagster import (
    graph_asset,
    Definitions,
    op,
    In,
    Nothing,
    AssetCheckResult,
    AssetCheckSpec,
    asset,
)

johannkm

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)