Add dagster tags to Sling stream(s)

[laenan8466]

Documentation says, that you can add tags to sling streams by implementing a custom DagsterSlingTranslator.

I tried that:

class CustomSlingTranslator(DagsterSlingTranslator):
    @override
    def get_tags(self, stream_definition: Mapping[str, Any]) -> Mapping[str, Any]:
        config = stream_definition.get("config", {}) or {}
        meta = config.get("meta", {})
        tags = meta.get("dagster", {}).get("tags")
        return {tag: '' for tag in tags}

Also tried with tag: 'true' and some variations of "tag/"+tag: 'true' with no success.

The replication.yaml has the following form:

...
streams:
  my_schema.my_table:
    meta:
      dagster:
        tags: ["tag1","tag2"]

What I looked into till now:

The asset_decorators.py module from dagster_embedded_etl defines the tag loading here:

def sling_assets(...):
   ...
   return multi_asset(
    ...
    specs=[
        AssetSpec(
            ...
            tags={
                **build_kind_tag("sling"),
                **(dagster_sling_translator.get_tags(stream) or {}),
            },
            ...
        )
        for stream in streams
    ],
  )

The build kind tag seems to be correctly inserted, and when using debugging in this function, also my tags seem to match the pattern.

I guess, I'm doing something wrong. Can someone spot my flaw?