[2m4:49PM[0m [92mINFO[0m [2mdb\etl.go:475[0m Closed unfinished batch loads from previous server instance [2mnum_batches_closed=[0m2 [2mnum_loads_closed=[0m0
[2m4:49PM[0m [92mINFO[0m listening on :8080
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T20:49:33.295Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T20:49:33.295Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-28T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-28T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T20:49:35.468Z
[2m4:49PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T20:49:35.468Z
[2m4:50PM[0m [92mINFO[0m shutting down — waiting for active requests to finish...
[2m4:50PM[0m [92mINFO[0m etl_batch_load query error: closed pool
pgw Query failed for sql: 
SELECT
    COALESCE(batch_load_id, 0),
    COALESCE(batch_summary, ''),
    COALESCE(is_latest, false),
    COALESCE(is_latest_success, false),
    COALESCE(load_scope_id, 0),
    COALESCE(load_scope, ''),
    COALESCE(execution_trigger, ''),
    COALESCE(sync_method, ''),
    COALESCE(num_workers, 0),
    COALESCE(include_extract_ids, '{}'::int[]),
    COALESCE(no_change_extract_ids, '{}'::int[]),
    COALESCE(incomplete_extract_ids, '{}'::int[]),
    COALESCE(batch_result, ''),
    batch_begin_at,
    batch_end_at,
		model_refresh_begin_at,
	  model_refresh_end_at,
    COALESCE(batch_error_summary, ''),
    COALESCE(batch_error_detail, ''),
    updated_at,
    COALESCE(created_by, 0),
    COALESCE(created_by_user, ''),
    COALESCE(num_tables, 0),
    COALESCE(num_success, 0),
    COALESCE(num_failed, 0),
    COALESCE(num_retry, 0),
    COALESCE(num_incomplete, 0),
    COALESCE(perc_success, 0)::double precision
FROM etl.v_batch_load
WHERE updated_at > $1
ORDER BY batch_load_id DESC
[2m4:51PM[0m [92mINFO[0m listening on :8080
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T20:52:03.814Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T20:52:03.814Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-20T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-20T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T20:52:06.806Z
[2m4:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T20:52:06.806Z
[2m5:30PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:30PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:30PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:30:22.316Z
[2m5:30PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:30:22.316Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:31:45.015Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:31:45.015Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:31:47.509Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:31:47.509Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:31:50.394Z
[2m5:31PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:31:50.394Z
[2m5:34PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:34PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:34PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:34:29.539Z
[2m5:34PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:34:29.539Z
[2m5:35PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:35PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:36:00.134Z
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:36:00.134Z
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:117[0m EtlRunOption [2mcreated_by_user=[0m""
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled"
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:36:49.035Z
[2m5:36PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:36:49.035Z
[2m5:37PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled"
[2m5:38PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:38PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m5:38PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T21:38:32.510Z
[2m5:38PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T21:38:32.510Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T22:51:23.096Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T22:51:23.096Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T22:51:25.351Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T22:51:25.351Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:51PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T22:52:00.513Z
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T22:52:00.513Z
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T22:52:02.829Z
[2m6:52PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T22:52:02.829Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-20T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-20T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T22:56:06.344Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T22:56:06.344Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T22:56:09.656Z
[2m6:56PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T22:56:09.656Z
[2m7:00PM[0m [92mINFO[0m shutting down — waiting for active requests to finish...
[2m7:01PM[0m [92mINFO[0m listening on :8080
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:01:06.059Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:01:06.059Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:01:12.367Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:01:12.367Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:01:13.406Z
[2m7:01PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:01:13.406Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:23:13.061Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:23:13.061Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:190[0m Etl_load query error due to context cancellation, ending stream [2merror=[0m"context canceled\npgw Query failed for sql: \nSELECT\n    COALESCE(sync_id, 0),\n    COALESCE(load_id, 0),\n    COALESCE(batch_load_id, 0),\n    COALESCE(extract_id, 0),\n    COALESCE(source_table, ''),\n    COALESCE(sink_table, ''),\n    COALESCE(load_scope, 0)::int,\n    COALESCE(execution_result, ''),\n    execution_begin_at,\n    execution_end_at,\n    COALESCE(execution_duration, ''),\n    expected_complete_at,\n    COALESCE(is_latest, false),\n    COALESCE(is_latest_success, false),\n    COALESCE(uri_query, ''),\n    prior_modified_at,\n    last_modified_at,\n    COALESCE(rows_staged, 0),\n    COALESCE(rows_inserted, 0),\n    COALESCE(rows_updated, 0),\n    COALESCE(rows_history, 0),\n    COALESCE(rows_deleted, 0),\n    COALESCE(rows_reinstated, 0),\n    COALESCE(rows_unchanged, 0),\n    COALESCE(rows_errored, 0),\n    COALESCE(error_summary, ''),\n    COALESCE(error_detail, ''),\n    COALESCE(subsequent_no_rows, 0),\n    no_rows_available_at,\n    updated_at,\n    enqueued_at,\n\t\tdequeued_at,\n    COALESCE(file_path, ''),\n    variables::text,\n    COALESCE(created_by, 0),\n    COALESCE(created_by_user, '')\nFROM etl.v_sync\nWHERE updated_at > $1\nORDER BY load_id DESC"
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:23:15.151Z
[2m7:23PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:23:15.151Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-04-22T00:00:00.000Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-14T00:00:00.000Z [2mto=[0m2026-04-22T00:00:00.000Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:29:30.765Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:29:30.765Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-29T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:29:33.791Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:29:33.791Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:150[0m EtlBatchLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:135[0m EtlLoadBetween [2mfrom=[0m2026-04-21T00:00:00.000Z [2mto=[0m2026-05-01T00:00:00.000Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:175[0m EtlLoad [2msince_time=[0m2026-04-29T23:29:35.615Z
[2m7:29PM[0m [92mINFO[0m [2mstreamer\streamer.go:246[0m EtlBatchLoad [2msince_time=[0m2026-04-29T23:29:35.615Z