tests.system.sqlite.example_sqlite

This is an example DAG for the use of the SQLExecuteQueryOperator with Sqlite. In this example, we create two tasks that execute in sequence. The first task calls an sql command, defined in the SQLite operator, which when triggered, is performed on the connected sqlite database. The second task is similar but instead calls the SQL command from an external file.

Attributes

ENV_ID

DAG_ID

create_table_sqlite_task

test_run

Module Contents

tests.system.sqlite.example_sqlite.ENV_ID[source]
tests.system.sqlite.example_sqlite.DAG_ID = 'example_sqlite'[source]
tests.system.sqlite.example_sqlite.create_table_sqlite_task[source]
tests.system.sqlite.example_sqlite.test_run[source]

Was this entry helpful?