From 5d722d2f2f1ed932d1e1ce18ad6ebe849a45ebae Mon Sep 17 00:00:00 2001 From: Guus Frenken Date: Thu, 16 Oct 2025 12:02:39 +0200 Subject: [PATCH 1/2] Add 'tags' arg to load_assets --- elx/extensions/dagster/assets.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/elx/extensions/dagster/assets.py b/elx/extensions/dagster/assets.py index e142f57..15d372e 100644 --- a/elx/extensions/dagster/assets.py +++ b/elx/extensions/dagster/assets.py @@ -22,6 +22,7 @@ def load_assets( deps: Iterable[AssetKey | str | Sequence[str] | AssetsDefinition | SourceAsset | AssetDep] | None = None, key_prefix: str | Sequence[str] | None = None, group_name: str | None = None, + tags: Mapping[str, str] | None = None, ) -> List[AssetsDefinition]: """ Load the assets for a runner, each asset represents one tap target combination. @@ -31,6 +32,7 @@ def load_assets( deps (Iterable[AssetKey | str | Sequence[str] | AssetsDefinition | SourceAsset | AssetDep] | None): Upstream assets upon which the assets depend. key_prefix (str | Sequence[str] | None): Key prefix for the assets. If not provided, defaults to the tap executable name. group_name (str | None): Group name for the assets. If not provided, defaults to the tap executable name. + tags (Mapping[str, str] | None): Tags for filtering and organizing. These tags are not attached to runs of the asset. Returns: List[AssetsDefinition]: The assets. @@ -85,6 +87,7 @@ def run(context: OpExecutionContext) -> Generator[Output, None, None]: description=generate_description(runner=runner, stream=stream), key_prefix=key_prefix or dagster_safe_name(runner.tap.executable), code_version=runner.tap.hash_key, + tags=tags, ) for stream in runner.tap.catalog.streams if stream.is_selected From 9ae5fd2a39854119ad60d3a97955652e6dff6896 Mon Sep 17 00:00:00 2001 From: Guus Frenken Date: Thu, 16 Oct 2025 12:06:23 +0200 Subject: [PATCH 2/2] Add 'tags' arg to load_assets --- elx/extensions/dagster/assets.py | 1 + 1 file changed, 1 insertion(+) diff --git a/elx/extensions/dagster/assets.py b/elx/extensions/dagster/assets.py index 15d372e..88de115 100644 --- a/elx/extensions/dagster/assets.py +++ b/elx/extensions/dagster/assets.py @@ -1,3 +1,4 @@ +from collections.abc import Mapping from typing import Generator, Iterable, List, Sequence from elx import Runner from dagster import (