Hello. I present this problem that I have trying t...
# integration-airbyte
a
Hello. I present this problem that I have trying to implement a dagster flow: I'm loading all my airbyte assets with this line of code:
airbyte_assets = load_assets_from_airbyte_instance(airbyte_instance)
Additionally, I have defined another asset that executes a stored procedure in SQL SERVER:
Copy code
@asset(
        group_name="sql_server_assets",
        retry_policy=RetryPolicy(max_retries=5, delay=60),
)
def sp_sql_server():
    
    # - Credenciales
    server = 'xxx'
    database = 'xxx'
    username = 'xxx'
    password = 'xxx'
    
    # - Cadena de conexión
    connection_string = f"DRIVER={{ODBC Driver 18 for SQL Server}};SERVER={server};DATABASE={database};UID={username};PWD={password}"

    with pyodbc.connect(connection_string) as connection:
        connection.execute("EXEC dbo.InsertTimestamp")

    return None
My problem lies in the need to define dependencies between assets, that is, I want my
sp_sql_server
asset to be executed first and then, through a dependency, a specific asset that is loaded from airbyte is executed, how can I do this? I reviewed the example by benpankow @ben that is on github and there I see a way to define this dependency but in this example it is done the other way around, that is, first the airbyte asset is executed and then the other assets that are defined under the
"non_argument_deps"
configuration "
"depends_on"
. how to achieve something similar but in reverse way? I thank you in advance for any help.
👀 1