File tree Expand file tree Collapse file tree
apps/bfd-pipeline-idr/test Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -653,13 +653,16 @@ def _test_load_progress_concurrent(conn: Connection) -> None:
653653 rows = cur .fetchmany (1 )
654654 assert rows_2 [0 ]["max_run_ts" ] == rows [0 ]["last_ts" ]
655655 # test table counts
656- cur = conn .execute ("select DISTINCT table_name from idr.load_progress where job_id = 1" \
657- " EXCEPT " \
658- "select DISTINCT table_name from idr.load_progress where job_id = 2" )
656+ cur = conn .execute (
657+ "select DISTINCT table_name from idr.load_progress where job_id = 1"
658+ " EXCEPT "
659+ "select DISTINCT table_name from idr.load_progress where job_id = 2"
660+ )
659661 rows = cur .fetchmany (1 )
660662 cur = conn .execute ("select count(*) as row_count from idr.load_progress where job_id = 2" )
661663 assert len (rows ) == 0
662664
665+
663666def test_initial_pipeline_load (postgres_db : tuple [PostgresContainer , str ]) -> None :
664667 _test_pipeline_load (postgres_db , LoadType .INITIAL )
665668
You can’t perform that action at this time.
0 commit comments