def get_sources(selected_assets, manifest):
    nodes = manifest["nodes"]
    sources = []
    for a in selected_assets:
        if f"model.xepelin_dw.{a}" in nodes.keys():
            node_info = nodes[f"model.xepelin_dw.{a}"]
            if len(node_info["sources"]) > 0:
                for s in node_info["sources"]:
                    sources.append("source:" + ".".join(s))

    return sources


@dbt_assets(manifest=manifest, select="*",exclude = "resource_type:snapshot")
def my_dbt_assets(context: OpExecutionContext, dbt: DbtCliResource):
    #try:
    selected_assets = [a[0][-1] for a in context.selected_asset_keys]
    sources = get_sources(selected_assets, manifest)
    #dbt.cli(["run"], context=context)
    if len(sources)>0:
        yield from dbt.cli(["test", "--select", " ".join(sources)], manifest=manifest).stream()
    else:
        <http://context.log.info|context.log.info>("No sources to test")
    yield from dbt.cli(["run"], context=context).stream()
    yield from dbt.cli(["test"], context=context).stream()