Dagster embeded etl - sling error on connection defition (sling could not find connection)

[igrpon]

My goal it to use sling to replicate data from postgres table into clickhouse one.

I use the following asset definition (quite standard, based on docs), however on the run (materialization) I got an error that sling could not find defined connection - why is so? how to fix that?

From the logs I see that dagster probably do not create connection definition for sling...

Exception: fatal:
~ could not prepare stream task: bi.table
could not find connection ch
Sling command failed:

My code

# Dagster asset - sync between Postgres DB (pg_cleancitydwh) and Clickhouse (ch_cleancitydwh)

from dagster_embedded_elt.sling import (
    SlingConnectionResource,
    SlingResource,
    sling_assets,
)

from dagster import EnvVar

#connection string for postgres
source = SlingConnectionResource(
    name="pg",
    type="postgres",
    host="host1.net",
    port="6432",
    database="prod",
    user="root",
    password=EnvVar("DBT_DB_PASS"),
)

target = SlingConnectionResource(
    name="ch",
    type="clikchouse",
    host="host2.net",
    port="9440",
    database="prod",
    user="root",
    password=EnvVar("DBT_DB_PASS"),
)

sling_resource = SlingResource(
    connections=[
        source,
        target,
    ]
)

replication_config = {
    "SOURCE": "pg",
    "TARGET": "ch",
    "defaults": {"mode": "full-refresh", "object": "{stream_table}"},       #"{stream_schema}_{stream_table}"
    "streams": {
        "bi.table": None,
    },
}

@sling_assets(replication_config=replication_config)
def datamarts_replication_pg2ch(context, sling: SlingResource):
    """
    Performs datamarts tables replication: tables in PostgreSQL DB into Clickhouse DB (for BI reports build over Clickhouse)
    """
    yield from sling.replicate(context=context)
    for row in sling.stream_raw_logs():
        context.log.info(row)

[hubmos]

Im experiencing the same issues, with a connectionresource of type "azure". Did you ever find a solution for this?