Skip to content

Commit 049a615

Browse files
jhfjhf
committed
test:Adapt to larger batch size
1 parent 0d3d165 commit 049a615

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

‎test/expected/305_load_norwegian_dataset_suitable_for_web_upload.out‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2930,7 +2930,7 @@ SELECT queue, state, count(*) FROM worker.tasks AS t JOIN worker.command_registr
29302930
queue | state | count
29312931
-----------+-----------+-------
29322932
analytics | pending | 7
2933-
import | completed | 100
2933+
import | completed | 95
29342934
(2 rows)
29352935

29362936
-- SET client_min_messages TO NOTICE;
@@ -3041,7 +3041,7 @@ SELECT queue, state, count(*) FROM worker.tasks AS t JOIN worker.command_registr
30413041
queue | state | count
30423042
-----------+-----------+-------
30433043
analytics | pending | 7
3044-
import | completed | 100
3044+
import | completed | 95
30453045
(2 rows)
30463046

30473047
\echo Run worker processing for analytics tasks
@@ -3051,7 +3051,7 @@ SELECT queue, state, count(*) FROM worker.tasks AS t JOIN worker.command_registr
30513051
queue | state | count
30523052
-----------+-----------+-------
30533053
analytics | completed | 9
3054-
import | completed | 100
3054+
import | completed | 95
30553055
(2 rows)
30563056

30573057
\echo "Checking statistics"
@@ -3127,15 +3127,15 @@ SELECT id AS lu_job_id FROM public.import_job WHERE slug = 'import_lu_web_exampl
31273127
SELECT slug, description, note, time_context_ident, default_valid_from, default_valid_to, default_data_source_code, upload_table_name, data_table_name, priority, analysis_batch_size, processing_batch_size , analysis_completed_pct , analysis_rows_per_sec , current_step_code , current_step_priority , max_analysis_priority , total_analysis_steps_weighted , completed_analysis_steps_weighted , total_rows , imported_rows , import_completed_pct , import_rows_per_sec , last_progress_update , state , error , review, edit_comment FROM public.import_job_clone(:lu_job_id, 'import_lu_clone');
31283128
slug | description | note | time_context_ident | default_valid_from | default_valid_to | default_data_source_code | upload_table_name | data_table_name | priority | analysis_batch_size | processing_batch_size | analysis_completed_pct | analysis_rows_per_sec | current_step_code | current_step_priority | max_analysis_priority | total_analysis_steps_weighted | completed_analysis_steps_weighted | total_rows | imported_rows | import_completed_pct | import_rows_per_sec | last_progress_update | state | error | review | edit_comment
31293129
-----------------+------------------------------------------------------------------+--------------------------------------------------------------------------------------------------------------------------------------+--------------------+--------------------+------------------+--------------------------+------------------------+----------------------+----------+---------------------+-----------------------+------------------------+-----------------------+-------------------+-----------------------+-----------------------+-------------------------------+-----------------------------------+------------+---------------+----------------------+---------------------+----------------------+--------------------+-------+--------+-------------------------------------------
3130-
import_lu_clone | Clone of job #1: Import Legal Units - Web Example (Current Year) | Import job for legal units from samples/norway/legal_unit/enheter-selection-web-import.csv using legal_unit_job_provided definition. | r_year_curr | 2026-01-01 | infinity | nlr | import_lu_clone_upload | import_lu_clone_data | | 32768 | 200 | 0.00 | | | | 100 | | 0 | | 0 | 0.00 | | | waiting_for_upload | | f | Test data load (01_load_web_examples.sql)
3130+
import_lu_clone | Clone of job #1: Import Legal Units - Web Example (Current Year) | Import job for legal units from samples/norway/legal_unit/enheter-selection-web-import.csv using legal_unit_job_provided definition. | r_year_curr | 2026-01-01 | infinity | nlr | import_lu_clone_upload | import_lu_clone_data | | 32768 | 1000 | 0.00 | | | | 100 | | 0 | | 0 | 0.00 | | | waiting_for_upload | | f | Test data load (01_load_web_examples.sql)
31313131
(1 row)
31323132

31333133
-- Clone establishment job
31343134
SELECT id AS es_job_id FROM public.import_job WHERE slug = 'import_es_web_example_current' \gset
31353135
SELECT slug, description, note, time_context_ident, default_valid_from, default_valid_to, default_data_source_code, upload_table_name, data_table_name, priority, analysis_batch_size, processing_batch_size , analysis_completed_pct , analysis_rows_per_sec , current_step_code , current_step_priority , max_analysis_priority , total_analysis_steps_weighted , completed_analysis_steps_weighted , total_rows , imported_rows , import_completed_pct , import_rows_per_sec , last_progress_update , state , error , review, edit_comment FROM public.import_job_clone(:es_job_id, 'import_es_clone');
31363136
slug | description | note | time_context_ident | default_valid_from | default_valid_to | default_data_source_code | upload_table_name | data_table_name | priority | analysis_batch_size | processing_batch_size | analysis_completed_pct | analysis_rows_per_sec | current_step_code | current_step_priority | max_analysis_priority | total_analysis_steps_weighted | completed_analysis_steps_weighted | total_rows | imported_rows | import_completed_pct | import_rows_per_sec | last_progress_update | state | error | review | edit_comment
31373137
-----------------+---------------------------------------------------------------------+-----------------------------------------------------------------------------------------------------------------------------------------------------------+--------------------+--------------------+------------------+--------------------------+------------------------+----------------------+----------+---------------------+-----------------------+------------------------+-----------------------+-------------------+-----------------------+-----------------------+-------------------------------+-----------------------------------+------------+---------------+----------------------+---------------------+----------------------+--------------------+-------+--------+-------------------------------------------
3138-
import_es_clone | Clone of job #2: Import Establishments - Web Example (Current Year) | Import job for establishments from samples/norway/establishment/underenheter-selection-web-import.csv using establishment_for_lu_job_provided definition. | r_year_curr | 2026-01-01 | infinity | nlr | import_es_clone_upload | import_es_clone_data | | 32768 | 200 | 0.00 | | | | 100 | | 0 | | 0 | 0.00 | | | waiting_for_upload | | f | Test data load (01_load_web_examples.sql)
3138+
import_es_clone | Clone of job #2: Import Establishments - Web Example (Current Year) | Import job for establishments from samples/norway/establishment/underenheter-selection-web-import.csv using establishment_for_lu_job_provided definition. | r_year_curr | 2026-01-01 | infinity | nlr | import_es_clone_upload | import_es_clone_data | | 32768 | 1000 | 0.00 | | | | 100 | | 0 | | 0 | 0.00 | | | waiting_for_upload | | f | Test data load (01_load_web_examples.sql)
31393139
(1 row)
31403140

31413141
-- SET client_min_messages TO DEBUG1;
@@ -3149,7 +3149,7 @@ SELECT queue, state, count(*) FROM worker.tasks AS t JOIN worker.command_registr
31493149
queue | state | count
31503150
-----------+-----------+-------
31513151
analytics | pending | 7
3152-
import | completed | 98
3152+
import | completed | 93
31533153
(2 rows)
31543154

31553155
-- SET client_min_messages TO NOTICE;

0 commit comments

Comments
 (0)