()
| 176 | |
| 177 | @dag(schedule=None, start_date=DEFAULT_DATE, catchup=False, default_args=default_args) |
| 178 | def dag_regular(): |
| 179 | nonlocal tasks_list |
| 180 | tasks = PipelineTasksGroup( |
| 181 | "pipeline_dag_regular", local_data_folder=get_test_storage_root(), wipe_local_data=False |
| 182 | ) |
| 183 | |
| 184 | pipeline_dag_regular = dlt.pipeline( |
| 185 | pipeline_name="pipeline_dag_regular", |
| 186 | dataset_name="mock_data_" + uniq_id(), |
| 187 | destination=dlt.destinations.duckdb(credentials=":pipeline:"), |
| 188 | ) |
| 189 | assert pipeline_dag_regular.get_local_state_val("initial_cwd").startswith( |
| 190 | os.path.abspath(get_test_storage_root()) |
| 191 | ) |
| 192 | tasks_list = tasks.add_run( |
| 193 | pipeline_dag_regular, |
| 194 | mock_data_source(), |
| 195 | decompose="none", |
| 196 | trigger_rule="all_done", |
| 197 | retries=0, |
| 198 | ) |
| 199 | |
| 200 | dag_def: DAG = dag_regular() |
| 201 | assert len(tasks_list) == 1 |
no test coverage detected