Error updating pipeline run and run step status!
Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1971, in _exec_single_context
    self.dialect.do_execute(
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/default.py", line 919, in do_execute
    cursor.execute(statement, parameters)
  File "/usr/local/lib/python3.12/site-packages/oracledb/cursor.py", line 710, in execute
    impl.execute(self)
  File "src/oracledb/impl/thin/cursor.pyx", line 196, in oracledb.thin_impl.ThinCursorImpl.execute
  File "src/oracledb/impl/thin/protocol.pyx", line 440, in oracledb.thin_impl.Protocol._process_single_message
  File "src/oracledb/impl/thin/protocol.pyx", line 441, in oracledb.thin_impl.Protocol._process_single_message
  File "src/oracledb/impl/thin/protocol.pyx", line 433, in oracledb.thin_impl.Protocol._process_message
  File "src/oracledb/impl/thin/messages.pyx", line 74, in oracledb.thin_impl.Message._check_and_raise_exception
oracledb.exceptions.DatabaseError: ORA-01704: string literal too long
Help: https://docs.oracle.com/error-help/db/ora-01704/

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/lib/python3.12/site-packages/dlt/extract/pipe_iterator.py", line 274, in _get_source_item
    pipe_item = next(gen)
                ^^^^^^^^^
  File "/worker/shared/task_handlers/run_pipeline/dlt_sources.py", line 1300, in enrichment_resource
    yield from _enrich_from_parquet(
  File "/worker/shared/task_handlers/run_pipeline/dlt_sources.py", line 1174, in _enrich_from_parquet
    query_result = conn.execute(text(cte_query), bind_params)
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1422, in execute
    return meth(
           ^^^^^
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", line 514, in _execute_on_connection
    return connection._execute_clauseelement(
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1644, in _execute_clauseelement
    ret = self._execute_context(
          ^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1850, in _execute_context
    return self._exec_single_context(
           ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1990, in _exec_single_context
    self._handle_dbapi_exception(
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 2357, in _handle_dbapi_exception
    raise sqlalchemy_exception.with_traceback(exc_info[2]) from e
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1971, in _exec_single_context
    self.dialect.do_execute(
  File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/default.py", line 919, in do_execute
    cursor.execute(statement, parameters)
  File "/usr/local/lib/python3.12/site-packages/oracledb/cursor.py", line 710, in execute
    impl.execute(self)
  File "src/oracledb/impl/thin/cursor.pyx", line 196, in oracledb.thin_impl.ThinCursorImpl.execute
  File "src/oracledb/impl/thin/protocol.pyx", line 440, in oracledb.thin_impl.Protocol._process_single_message
  File "src/oracledb/impl/thin/protocol.pyx", line 441, in oracledb.thin_impl.Protocol._process_single_message
  File "src/oracledb/impl/thin/protocol.pyx", line 433, in oracledb.thin_impl.Protocol._process_message
  File "src/oracledb/impl/thin/messages.pyx", line 74, in oracledb.thin_impl.Message._check_and_raise_exception
sqlalchemy.exc.DatabaseError: (oracledb.exceptions.DatabaseError) ORA-01704: string literal too long
Help: https://docs.oracle.com/error-help/db/ora-01704/
[SQL: WITH pipeline_get_charges AS (
    SELECT charge_item_id, parent_charge_item_id, charge_event_act_id, charge_event_id, bill_item_id, order_id, encntr_id, person_id, payor_id, ord_loc_cd, perf_loc_cd, ord_phys_id, perf_phys_id, charge_description, price_sched_id, item_quantity, item_price, item_extended_price, item_allowable, item_copay, charge_type_cd, research_acct_id, suspense_rsn_cd, reason_comment, posted_cd, posted_dt_tm, process_flg, service_dt_tm, activity_dt_tm, updt_cnt, updt_dt_tm, updt_id, updt_task, updt_applctx, active_ind, active_status_cd, active_status_dt_tm, active_status_prsnl_id, beg_effective_dt_tm, end_effective_dt_tm, credited_dt_tm, adjusted_dt_tm, interface_file_id, tier_group_cd, def_bill_item_id, verify_phys_id, gross_price, discount_amount, manual_ind, combine_ind, bundle_id, institution_cd, department_cd, section_cd, subsection_cd, level5_cd, admit_type_cd, med_service_cd, activity_type_cd, inst_fin_nbr, cost_center_cd, abn_status_cd, health_plan_id, fin_class_cd, item_interval_id, item_list_price, item_reimbursement, list_price_sched_id, payor_type_cd, epsdt_ind, ref_phys_id, start_dt_tm, stop_dt_tm, alpha_nomen_id, server_process_flag, item_deductible_amt, patient_responsibility_flag, offset_charge_item_id, cs_cpp_undo_id, cs_cpp_undo_qual_id, posted_id, pricing_status_cd, activity_sub_type_cd, provider_specialty_cd, last_utc_ts, inst_id, original_org_id, txn_id_text, original_encntr_id, service_interface_flag, item_price_adj_amt
    FROM JSON_TABLE('[{"charge_item_id": 0, "parent_charge_item_id": 0, "charge_event_act_id": 0, "charge_event_id": 0, "bill_item_id": 0, "order_id": 0, "encntr_id": 0, "person_id": 0, "payor_id": 0, "ord_loc_cd": 0, "perf_loc_cd": 0, "ord_phys_id": 0, "perf_phys_id": 0, "charge_description": null, "price_sched_id": 0, "item_quantity": 0.0, "item_price": 0.0, "item_extended_price": 0.0, "item_allowable": 0.0, "item_copay": 0.0, "charge_type_cd": 0, "research_acct_id": 0, "suspense_rsn_cd": 0, "reason_comment": null, "posted_cd": 0, "posted_dt_tm": null, "process_flg": 0, "service_dt_tm": null, "activity_dt_tm": null, "updt_cnt": 0, "updt_dt_tm": null, "updt_id": 0, "updt_task": 0, "updt_applctx": 0, "active_ind": 0, "active_status_cd": 0, "active_status_dt_tm": null, "active_status_prsnl_id": 0, "beg_effective_dt_tm": null, "end_effective_dt_tm": null, "credited_dt_tm": null, "adjusted_dt_tm": null, "interface_file_id": 0, "tier_group_cd": 0, "def_bill_item_id": 0, "verify_phys_id": 0, "gross_price": 0.0, "discount_amount": 0.0, "manual_ind": 0, "combine_ind": 0, "bundle_id": 0, "institution_cd": 0, "department_cd": 0, "section_cd": 0, "subsection_cd": 0, "level5_cd": 0, "admit_type_cd": 0, "med_service_cd": 0, "activity_type_cd": 0, "inst_fin_nbr": null, "cost_center_cd": 0, "abn_status_cd": 0, "health_plan_id": 0, "fin_class_cd": 0, "item_interval_id": 0, "item_list_price": 0.0, "item_reimbursement": 0.0, "list_price_sched_id": 0, "payor_type_cd": 0, "epsdt_ind": 0, "ref_phys_id": 0, "start_dt_tm": null, "stop_dt_tm": null, "alpha_nomen_id": 0, "server_process_flag": 0, "item_deductible_amt": 0.0, "patient_responsibility_flag": 0, "offset_charge_item_id": 0, "cs_cpp_undo_id": 0, "cs_cpp_undo_qual_id": 0, "posted_id": 0, "pricing_status_cd": 0, "activity_sub_type_cd": 0, "provider_specialty_cd": 0, "last_utc_ts": null, "inst_id": 0, "original_org_id": 0, "txn_id_text": null, "original_encntr_id": 0, "service_interface_flag": 0, "item_price_adj_amt": 0.0}, {"charge_item_id": 1000, "parent_charge_item_id": 0, "charge_event_act_id": 0, "charge_event_id": 1001, "bill_item_id": 1687, "order_id": 0, "encntr_id": 1000, "person_id": 1000, "payor_id": 0, "ord_loc_cd": 0, "perf_loc_cd": 0, "ord_phys_id": 1, "perf_phys_id": 0, "charge_description": "Urgent Care Level 2 New", "price_sched_id": 0, "item_quantity": 1.0, "item_price": 101.5, "item_extended_price": 101.5, "item_allowable": 0.0, "item_copay": 0.0, "charge_type_cd": 3490, "research_acct_id": 0, "suspense_rsn_cd": 0, "reason_comment": null, "posted_cd": 0, "posted_dt_tm": "2025-10-14T08:39:32", "process_flg": 999, "service_dt_tm": "2025-10-14T08:39:32", "activity_dt_tm": "2025-10-22T13:12:44", "updt_cnt": 1, "updt_dt_tm": "2025-10-22T18:12:44", "updt_id": 16, "updt_task": 0, "updt_applctx": 0, "active_ind": 1, "active_status_cd": 188, "active_status_dt_tm": "2025-10-14T08:39:32", "active_status_prsnl_id": 16, "beg_effective_dt_tm": null, "end_effective_dt_tm": null, "credited_dt_tm": null, "adjusted_dt_tm": null, "interface_file_id": 1, "tier_group_cd": 1930366971, "def_bill_item_id": 0, "verify_phys_id": 1, "gross_price": 0.0, "discount_amount": 0.0, "manual_ind": 0, "combine_ind": 0, "bundle_id": 0, "institution_cd": 0, "department_cd": 0, "section_cd": 0, "subsection_cd": 0, "level5_cd": 0, "admit_type_cd": 0, "med_service_cd": 0, "activity_type_cd": 3542639, "inst_fin_nbr": null, "cost_center_cd": 0, "abn_status_cd": 0, "health_plan_id": 0, "fin_class_cd": 0, "item_interval_id": 0, "item_list_price": 0.0, "item_reimbursement": 0.0, "list_price_sched_id": 0, "payor_type_cd": 0, "epsdt_ind": 0, "ref_phys_id": 0, "start_dt_tm": null, "stop_dt_tm": null, "alpha_nomen_id": 0, "server_process_flag": 0, "item_deductible_amt": 0.0, "patient_responsibility_flag": 0, "offset_charge_item_id": 0, "cs_cpp_undo_id": 0, "cs_cpp_undo_qual_id": 0, "posted_id": 0, "pricing_status_cd": 0, "activity_sub_type_cd": 0, "provider_specialty_cd": 0, "last_utc_ts": null, "inst_id": 0, "original_org_id": 0, "txn_id_text": null, "original_encntr_id": 0, "service_interface_flag": 0, "item_price_adj_amt": 0.0}, {"charge_item_id": 1005, "parent_charge_item_id": 0, "charge_event_act_id": 0, "charge_event_id": 1006, "bill_item_id": 1687, "order_id": 0, "encntr_id": 1000, "person_id": 1000, "payor_id": 0, "ord_loc_cd": 0, "perf_loc_cd": 0, "ord_phys_id": 1, "perf_phys_id": 0, "charge_description": "Urgent Care Level 2 New", "price_sched_id": 0, "item_quantity": 1.0, "item_price": 101.5, "item_extended_price": 101.5, "item_allowable": 0.0, "item_copay": 0.0, "charge_type_cd": 3490, "research_acct_id": 0, "suspense_rsn_cd": 0, "reason_comment": null, "posted_cd": 0, "posted_dt_tm": "2025-10-14T08:22:27", "process_flg": 999, "service_dt_tm": "2025-10-14T08:22:27", "activity_dt_tm": "2025-10-22T13:12:44", "updt_cnt": 1, "updt_dt_tm": "2025-10-22T18:12:44", "updt_id": 16, "updt_task": 0, "updt_applctx": 0, "active_ind": 1, "active_status_cd": 188, "active_status_dt_tm": "2025-10-14T08:22:27", "active_status_prsnl_id": 16, "beg_effective_dt_tm": null, "end_effective_dt_tm": null, "credited_dt_tm": null, "adjusted_dt_tm": null, "interface_file_id": 1, "tier_group_cd": 1882715601, "def_bill_item_id": 0, "verify_phys_id": 1, "gross_price": 0.0, "discount_amount": 0.0, "manual_ind": 0, "combine_ind": 0, "bundle_id": 0, "institution_cd": 0, "department_cd": 0, "section_cd": 0, "subsection_cd": 0, "level5_cd": 0, "admit_type_cd": 0, "med_service_cd": 0, "activity_type_cd": 3542639, "inst_fin_nbr": null, "cost_center_cd": 0, "abn_status_cd": 0, "health_plan_id": 0, "fin_class_cd": 0, "item_interval_id": 0, "item_list_price": 0.0, "item_reimbursement": 0.0, "list_price_sched_id": 0, "payor_type_cd": 0, "epsdt_ind": 0, "ref_phys_id": 0, "start_dt_tm": null, "stop_dt_tm": null, "alpha_nomen_id": 0, "server_process_flag": 0, "item_deductible_amt": 0.0, "patient_responsibility_flag": 0, "offset_charge_item_id": 0, "cs_cpp_undo_id": 0, "cs_cpp_undo_qual_id": 0, "posted_id": 0, "pricing_status_cd": 0, "activity_sub_type_cd": 0, "provider_specialty_cd": 0, "last_utc_ts": null, "inst_id": 0, "original_org_id": 0, "txn_id_text": null, "original_encntr_id": 0, "service_interface_flag": 0, "item_price_adj_amt": 0.0}]', '$[*]'
        COLUMNS (
            charge_item_id VARCHAR2(4000) PATH '$.charge_item_id', parent_charge_item_id VARCHAR2(4000) PATH '$.parent_charge_item_id', charge_event_act_id VARCHAR2(4000) PATH '$.charge_event_act_id', charge_event_id VARCHAR2(4000) PATH '$.charge_event_id', bill_item_id VARCHAR2(4000) PATH '$.bill_item_id', order_id VARCHAR2(4000) PATH '$.order_id', encntr_id VARCHAR2(4000) PATH '$.encntr_id', person_id VARCHAR2(4000) PATH '$.person_id', payor_id VARCHAR2(4000) PATH '$.payor_id', ord_loc_cd VARCHAR2(4000) PATH '$.ord_loc_cd', perf_loc_cd VARCHAR2(4000) PATH '$.perf_loc_cd', ord_phys_id VARCHAR2(4000) PATH '$.ord_phys_id', perf_phys_id VARCHAR2(4000) PATH '$.perf_phys_id', charge_description VARCHAR2(4000) PATH '$.charge_description', price_sched_id VARCHAR2(4000) PATH '$.price_sched_id', item_quantity VARCHAR2(4000) PATH '$.item_quantity', item_price VARCHAR2(4000) PATH '$.item_price', item_extended_price VARCHAR2(4000) PATH '$.item_extended_price', item_allowable VARCHAR2(4000) PATH '$.item_allowable', item_copay VARCHAR2(4000) PATH '$.item_copay', charge_type_cd VARCHAR2(4000) PATH '$.charge_type_cd', research_acct_id VARCHAR2(4000) PATH '$.research_acct_id', suspense_rsn_cd VARCHAR2(4000) PATH '$.suspense_rsn_cd', reason_comment VARCHAR2(4000) PATH '$.reason_comment', posted_cd VARCHAR2(4000) PATH '$.posted_cd', posted_dt_tm VARCHAR2(4000) PATH '$.posted_dt_tm', process_flg VARCHAR2(4000) PATH '$.process_flg', service_dt_tm VARCHAR2(4000) PATH '$.service_dt_tm', activity_dt_tm VARCHAR2(4000) PATH '$.activity_dt_tm', updt_cnt VARCHAR2(4000) PATH '$.updt_cnt', updt_dt_tm VARCHAR2(4000) PATH '$.updt_dt_tm', updt_id VARCHAR2(4000) PATH '$.updt_id', updt_task VARCHAR2(4000) PATH '$.updt_task', updt_applctx VARCHAR2(4000) PATH '$.updt_applctx', active_ind VARCHAR2(4000) PATH '$.active_ind', active_status_cd VARCHAR2(4000) PATH '$.active_status_cd', active_status_dt_tm VARCHAR2(4000) PATH '$.active_status_dt_tm', active_status_prsnl_id VARCHAR2(4000) PATH '$.active_status_prsnl_id', beg_effective_dt_tm VARCHAR2(4000) PATH '$.beg_effective_dt_tm', end_effective_dt_tm VARCHAR2(4000) PATH '$.end_effective_dt_tm', credited_dt_tm VARCHAR2(4000) PATH '$.credited_dt_tm', adjusted_dt_tm VARCHAR2(4000) PATH '$.adjusted_dt_tm', interface_file_id VARCHAR2(4000) PATH '$.interface_file_id', tier_group_cd VARCHAR2(4000) PATH '$.tier_group_cd', def_bill_item_id VARCHAR2(4000) PATH '$.def_bill_item_id', verify_phys_id VARCHAR2(4000) PATH '$.verify_phys_id', gross_price VARCHAR2(4000) PATH '$.gross_price', discount_amount VARCHAR2(4000) PATH '$.discount_amount', manual_ind VARCHAR2(4000) PATH '$.manual_ind', combine_ind VARCHAR2(4000) PATH '$.combine_ind', bundle_id VARCHAR2(4000) PATH '$.bundle_id', institution_cd VARCHAR2(4000) PATH '$.institution_cd', department_cd VARCHAR2(4000) PATH '$.department_cd', section_cd VARCHAR2(4000) PATH '$.section_cd', subsection_cd VARCHAR2(4000) PATH '$.subsection_cd', level5_cd VARCHAR2(4000) PATH '$.level5_cd', admit_type_cd VARCHAR2(4000) PATH '$.admit_type_cd', med_service_cd VARCHAR2(4000) PATH '$.med_service_cd', activity_type_cd VARCHAR2(4000) PATH '$.activity_type_cd', inst_fin_nbr VARCHAR2(4000) PATH '$.inst_fin_nbr', cost_center_cd VARCHAR2(4000) PATH '$.cost_center_cd', abn_status_cd VARCHAR2(4000) PATH '$.abn_status_cd', health_plan_id VARCHAR2(4000) PATH '$.health_plan_id', fin_class_cd VARCHAR2(4000) PATH '$.fin_class_cd', item_interval_id VARCHAR2(4000) PATH '$.item_interval_id', item_list_price VARCHAR2(4000) PATH '$.item_list_price', item_reimbursement VARCHAR2(4000) PATH '$.item_reimbursement', list_price_sched_id VARCHAR2(4000) PATH '$.list_price_sched_id', payor_type_cd VARCHAR2(4000) PATH '$.payor_type_cd', epsdt_ind VARCHAR2(4000) PATH '$.epsdt_ind', ref_phys_id VARCHAR2(4000) PATH '$.ref_phys_id', start_dt_tm VARCHAR2(4000) PATH '$.start_dt_tm', stop_dt_tm VARCHAR2(4000) PATH '$.stop_dt_tm', alpha_nomen_id VARCHAR2(4000) PATH '$.alpha_nomen_id', server_process_flag VARCHAR2(4000) PATH '$.server_process_flag', item_deductible_amt VARCHAR2(4000) PATH '$.item_deductible_amt', patient_responsibility_flag VARCHAR2(4000) PATH '$.patient_responsibility_flag', offset_charge_item_id VARCHAR2(4000) PATH '$.offset_charge_item_id', cs_cpp_undo_id VARCHAR2(4000) PATH '$.cs_cpp_undo_id', cs_cpp_undo_qual_id VARCHAR2(4000) PATH '$.cs_cpp_undo_qual_id', posted_id VARCHAR2(4000) PATH '$.posted_id', pricing_status_cd VARCHAR2(4000) PATH '$.pricing_status_cd', activity_sub_type_cd VARCHAR2(4000) PATH '$.activity_sub_type_cd', provider_specialty_cd VARCHAR2(4000) PATH '$.provider_specialty_cd', last_utc_ts VARCHAR2(4000) PATH '$.last_utc_ts', inst_id VARCHAR2(4000) PATH '$.inst_id', original_org_id VARCHAR2(4000) PATH '$.original_org_id', txn_id_text VARCHAR2(4000) PATH '$.txn_id_text', original_encntr_id VARCHAR2(4000) PATH '$.original_encntr_id', service_interface_flag VARCHAR2(4000) PATH '$.service_interface_flag', item_price_adj_amt VARCHAR2(4000) PATH '$.item_price_adj_amt'
        )
    )
)
select * from charge c
join pipeline_get_charges gc on
gc.charge_item_id = c.charge_item_id]
(Background on this error at: https://sqlalche.me/e/20/4xp6)

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/worker/shared/task_handlers/run_pipeline/pipeline.py", line 2291, in run_pipeline
    metadata, dlt_source = get_metadata(dlt_source)
                           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/worker/shared/logging/ps_logging.py", line 58, in wrapper
    result = func(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^^^
  File "/worker/shared/pipelines/pipeline_utils.py", line 1027, in get_metadata
    table = next(iter(obj))
            ^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/dlt/common/utils.py", line 146, in flatten_list_or_items
    for items in _iter:
                 ^^^^^
dlt.extract.exceptions.ResourceExtractionError: In processing pipe enrich: extraction of resource enrich in generator enrichment_resource caused an exception: (oracledb.exceptions.DatabaseError) ORA-01704: string literal too long
Help: https://docs.oracle.com/error-help/db/ora-01704/
[SQL: WITH pipeline_get_charges AS (
    SELECT charge_item_id, parent_charge_item_id, charge_event_act_id, charge_event_id, bill_item_id, order_id, encntr_id, person_id, payor_id, ord_loc_cd, perf_loc_cd, ord_phys_id, perf_phys_id, charge_description, price_sched_id, item_quantity, item_price, item_extended_price, item_allowable, item_copay, charge_type_cd, research_acct_id, suspense_rsn_cd, reason_comment, posted_cd, posted_dt_tm, process_flg, service_dt_tm, activity_dt_tm, updt_cnt, updt_dt_tm, updt_id, updt_task, updt_applctx, active_ind, active_status_cd, active_status_dt_tm, active_status_prsnl_id, beg_effective_dt_tm, end_effective_dt_tm, credited_dt_tm, adjusted_dt_tm, interface_file_id, tier_group_cd, def_bill_item_id, verify_phys_id, gross_price, discount_amount, manual_ind, combine_ind, bundle_id, institution_cd, department_cd, section_cd, subsection_cd, level5_cd, admit_type_cd, med_service_cd, activity_type_cd, inst_fin_nbr, cost_center_cd, abn_status_cd, health_plan_id, fin_class_cd, item_interval_id, item_list_price, item_reimbursement, list_price_sched_id, payor_type_cd, epsdt_ind, ref_phys_id, start_dt_tm, stop_dt_tm, alpha_nomen_id, server_process_flag, item_deductible_amt, patient_responsibility_flag, offset_charge_item_id, cs_cpp_undo_id, cs_cpp_undo_qual_id, posted_id, pricing_status_cd, activity_sub_type_cd, provider_specialty_cd, last_utc_ts, inst_id, original_org_id, txn_id_text, original_encntr_id, service_interface_flag, item_price_adj_amt
    FROM JSON_TABLE('[{"charge_item_id": 0, "parent_charge_item_id": 0, "charge_event_act_id": 0, "charge_event_id": 0, "bill_item_id": 0, "order_id": 0, "encntr_id": 0, "person_id": 0, "payor_id": 0, "ord_loc_cd": 0, "perf_loc_cd": 0, "ord_phys_id": 0, "perf_phys_id": 0, "charge_description": null, "price_sched_id": 0, "item_quantity": 0.0, "item_price": 0.0, "item_extended_price": 0.0, "item_allowable": 0.0, "item_copay": 0.0, "charge_type_cd": 0, "research_acct_id": 0, "suspense_rsn_cd": 0, "reason_comment": null, "posted_cd": 0, "posted_dt_tm": null, "process_flg": 0, "service_dt_tm": null, "activity_dt_tm": null, "updt_cnt": 0, "updt_dt_tm": null, "updt_id": 0, "updt_task": 0, "updt_applctx": 0, "active_ind": 0, "active_status_cd": 0, "active_status_dt_tm": null, "active_status_prsnl_id": 0, "beg_effective_dt_tm": null, "end_effective_dt_tm": null, "credited_dt_tm": null, "adjusted_dt_tm": null, "interface_file_id": 0, "tier_group_cd": 0, "def_bill_item_id": 0, "verify_phys_id": 0, "gross_price": 0.0, "discount_amount": 0.0, "manual_ind": 0, "combine_ind": 0, "bundle_id": 0, "institution_cd": 0, "department_cd": 0, "section_cd": 0, "subsection_cd": 0, "level5_cd": 0, "admit_type_cd": 0, "med_service_cd": 0, "activity_type_cd": 0, "inst_fin_nbr": null, "cost_center_cd": 0, "abn_status_cd": 0, "health_plan_id": 0, "fin_class_cd": 0, "item_interval_id": 0, "item_list_price": 0.0, "item_reimbursement": 0.0, "list_price_sched_id": 0, "payor_type_cd": 0, "epsdt_ind": 0, "ref_phys_id": 0, "start_dt_tm": null, "stop_dt_tm": null, "alpha_nomen_id": 0, "server_process_flag": 0, "item_deductible_amt": 0.0, "patient_responsibility_flag": 0, "offset_charge_item_id": 0, "cs_cpp_undo_id": 0, "cs_cpp_undo_qual_id": 0, "posted_id": 0, "pricing_status_cd": 0, "activity_sub_type_cd": 0, "provider_specialty_cd": 0, "last_utc_ts": null, "inst_id": 0, "original_org_id": 0, "txn_id_text": null, "original_encntr_id": 0, "service_interface_flag": 0, "item_price_adj_amt": 0.0}, {"charge_item_id": 1000, "parent_charge_item_id": 0, "charge_event_act_id": 0, "charge_event_id": 1001, "bill_item_id": 1687, "order_id": 0, "encntr_id": 1000, "person_id": 1000, "payor_id": 0, "ord_loc_cd": 0, "perf_loc_cd": 0, "ord_phys_id": 1, "perf_phys_id": 0, "charge_description": "Urgent Care Level 2 New", "price_sched_id": 0, "item_quantity": 1.0, "item_price": 101.5, "item_extended_price": 101.5, "item_allowable": 0.0, "item_copay": 0.0, "charge_type_cd": 3490, "research_acct_id": 0, "suspense_rsn_cd": 0, "reason_comment": null, "posted_cd": 0, "posted_dt_tm": "2025-10-14T08:39:32", "process_flg": 999, "service_dt_tm": "2025-10-14T08:39:32", "activity_dt_tm": "2025-10-22T13:12:44", "updt_cnt": 1, "updt_dt_tm": "2025-10-22T18:12:44", "updt_id": 16, "updt_task": 0, "updt_applctx": 0, "active_ind": 1, "active_status_cd": 188, "active_status_dt_tm": "2025-10-14T08:39:32", "active_status_prsnl_id": 16, "beg_effective_dt_tm": null, "end_effective_dt_tm": null, "credited_dt_tm": null, "adjusted_dt_tm": null, "interface_file_id": 1, "tier_group_cd": 1930366971, "def_bill_item_id": 0, "verify_phys_id": 1, "gross_price": 0.0, "discount_amount": 0.0, "manual_ind": 0, "combine_ind": 0, "bundle_id": 0, "institution_cd": 0, "department_cd": 0, "section_cd": 0, "subsection_cd": 0, "level5_cd": 0, "admit_type_cd": 0, "med_service_cd": 0, "activity_type_cd": 3542639, "inst_fin_nbr": null, "cost_center_cd": 0, "abn_status_cd": 0, "health_plan_id": 0, "fin_class_cd": 0, "item_interval_id": 0, "item_list_price": 0.0, "item_reimbursement": 0.0, "list_price_sched_id": 0, "payor_type_cd": 0, "epsdt_ind": 0, "ref_phys_id": 0, "start_dt_tm": null, "stop_dt_tm": null, "alpha_nomen_id": 0, "server_process_flag": 0, "item_deductible_amt": 0.0, "patient_responsibility_flag": 0, "offset_charge_item_id": 0, "cs_cpp_undo_id": 0, "cs_cpp_undo_qual_id": 0, "posted_id": 0, "pricing_status_cd": 0, "activity_sub_type_cd": 0, "provider_specialty_cd": 0, "last_utc_ts": null, "inst_id": 0, "original_org_id": 0, "txn_id_text": null, "original_encntr_id": 0, "service_interface_flag": 0, "item_price_adj_amt": 0.0}, {"charge_item_id": 1005, "parent_charge_item_id": 0, "charge_event_act_id": 0, "charge_event_id": 1006, "bill_item_id": 1687, "order_id": 0, "encntr_id": 1000, "person_id": 1000, "payor_id": 0, "ord_loc_cd": 0, "perf_loc_cd": 0, "ord_phys_id": 1, "perf_phys_id": 0, "charge_description": "Urgent Care Level 2 New", "price_sched_id": 0, "item_quantity": 1.0, "item_price": 101.5, "item_extended_price": 101.5, "item_allowable": 0.0, "item_copay": 0.0, "charge_type_cd": 3490, "research_acct_id": 0, "suspense_rsn_cd": 0, "reason_comment": null, "posted_cd": 0, "posted_dt_tm": "2025-10-14T08:22:27", "process_flg": 999, "service_dt_tm": "2025-10-14T08:22:27", "activity_dt_tm": "2025-10-22T13:12:44", "updt_cnt": 1, "updt_dt_tm": "2025-10-22T18:12:44", "updt_id": 16, "updt_task": 0, "updt_applctx": 0, "active_ind": 1, "active_status_cd": 188, "active_status_dt_tm": "2025-10-14T08:22:27", "active_status_prsnl_id": 16, "beg_effective_dt_tm": null, "end_effective_dt_tm": null, "credited_dt_tm": null, "adjusted_dt_tm": null, "interface_file_id": 1, "tier_group_cd": 1882715601, "def_bill_item_id": 0, "verify_phys_id": 1, "gross_price": 0.0, "discount_amount": 0.0, "manual_ind": 0, "combine_ind": 0, "bundle_id": 0, "institution_cd": 0, "department_cd": 0, "section_cd": 0, "subsection_cd": 0, "level5_cd": 0, "admit_type_cd": 0, "med_service_cd": 0, "activity_type_cd": 3542639, "inst_fin_nbr": null, "cost_center_cd": 0, "abn_status_cd": 0, "health_plan_id": 0, "fin_class_cd": 0, "item_interval_id": 0, "item_list_price": 0.0, "item_reimbursement": 0.0, "list_price_sched_id": 0, "payor_type_cd": 0, "epsdt_ind": 0, "ref_phys_id": 0, "start_dt_tm": null, "stop_dt_tm": null, "alpha_nomen_id": 0, "server_process_flag": 0, "item_deductible_amt": 0.0, "patient_responsibility_flag": 0, "offset_charge_item_id": 0, "cs_cpp_undo_id": 0, "cs_cpp_undo_qual_id": 0, "posted_id": 0, "pricing_status_cd": 0, "activity_sub_type_cd": 0, "provider_specialty_cd": 0, "last_utc_ts": null, "inst_id": 0, "original_org_id": 0, "txn_id_text": null, "original_encntr_id": 0, "service_interface_flag": 0, "item_price_adj_amt": 0.0}]', '$[*]'
        COLUMNS (
            charge_item_id VARCHAR2(4000) PATH '$.charge_item_id', parent_charge_item_id VARCHAR2(4000) PATH '$.parent_charge_item_id', charge_event_act_id VARCHAR2(4000) PATH '$.charge_event_act_id', charge_event_id VARCHAR2(4000) PATH '$.charge_event_id', bill_item_id VARCHAR2(4000) PATH '$.bill_item_id', order_id VARCHAR2(4000) PATH '$.order_id', encntr_id VARCHAR2(4000) PATH '$.encntr_id', person_id VARCHAR2(4000) PATH '$.person_id', payor_id VARCHAR2(4000) PATH '$.payor_id', ord_loc_cd VARCHAR2(4000) PATH '$.ord_loc_cd', perf_loc_cd VARCHAR2(4000) PATH '$.perf_loc_cd', ord_phys_id VARCHAR2(4000) PATH '$.ord_phys_id', perf_phys_id VARCHAR2(4000) PATH '$.perf_phys_id', charge_description VARCHAR2(4000) PATH '$.charge_description', price_sched_id VARCHAR2(4000) PATH '$.price_sched_id', item_quantity VARCHAR2(4000) PATH '$.item_quantity', item_price VARCHAR2(4000) PATH '$.item_price', item_extended_price VARCHAR2(4000) PATH '$.item_extended_price', item_allowable VARCHAR2(4000) PATH '$.item_allowable', item_copay VARCHAR2(4000) PATH '$.item_copay', charge_type_cd VARCHAR2(4000) PATH '$.charge_type_cd', research_acct_id VARCHAR2(4000) PATH '$.research_acct_id', suspense_rsn_cd VARCHAR2(4000) PATH '$.suspense_rsn_cd', reason_comment VARCHAR2(4000) PATH '$.reason_comment', posted_cd VARCHAR2(4000) PATH '$.posted_cd', posted_dt_tm VARCHAR2(4000) PATH '$.posted_dt_tm', process_flg VARCHAR2(4000) PATH '$.process_flg', service_dt_tm VARCHAR2(4000) PATH '$.service_dt_tm', activity_dt_tm VARCHAR2(4000) PATH '$.activity_dt_tm', updt_cnt VARCHAR2(4000) PATH '$.updt_cnt', updt_dt_tm VARCHAR2(4000) PATH '$.updt_dt_tm', updt_id VARCHAR2(4000) PATH '$.updt_id', updt_task VARCHAR2(4000) PATH '$.updt_task', updt_applctx VARCHAR2(4000) PATH '$.updt_applctx', active_ind VARCHAR2(4000) PATH '$.active_ind', active_status_cd VARCHAR2(4000) PATH '$.active_status_cd', active_status_dt_tm VARCHAR2(4000) PATH '$.active_status_dt_tm', active_status_prsnl_id VARCHAR2(4000) PATH '$.active_status_prsnl_id', beg_effective_dt_tm VARCHAR2(4000) PATH '$.beg_effective_dt_tm', end_effective_dt_tm VARCHAR2(4000) PATH '$.end_effective_dt_tm', credited_dt_tm VARCHAR2(4000) PATH '$.credited_dt_tm', adjusted_dt_tm VARCHAR2(4000) PATH '$.adjusted_dt_tm', interface_file_id VARCHAR2(4000) PATH '$.interface_file_id', tier_group_cd VARCHAR2(4000) PATH '$.tier_group_cd', def_bill_item_id VARCHAR2(4000) PATH '$.def_bill_item_id', verify_phys_id VARCHAR2(4000) PATH '$.verify_phys_id', gross_price VARCHAR2(4000) PATH '$.gross_price', discount_amount VARCHAR2(4000) PATH '$.discount_amount', manual_ind VARCHAR2(4000) PATH '$.manual_ind', combine_ind VARCHAR2(4000) PATH '$.combine_ind', bundle_id VARCHAR2(4000) PATH '$.bundle_id', institution_cd VARCHAR2(4000) PATH '$.institution_cd', department_cd VARCHAR2(4000) PATH '$.department_cd', section_cd VARCHAR2(4000) PATH '$.section_cd', subsection_cd VARCHAR2(4000) PATH '$.subsection_cd', level5_cd VARCHAR2(4000) PATH '$.level5_cd', admit_type_cd VARCHAR2(4000) PATH '$.admit_type_cd', med_service_cd VARCHAR2(4000) PATH '$.med_service_cd', activity_type_cd VARCHAR2(4000) PATH '$.activity_type_cd', inst_fin_nbr VARCHAR2(4000) PATH '$.inst_fin_nbr', cost_center_cd VARCHAR2(4000) PATH '$.cost_center_cd', abn_status_cd VARCHAR2(4000) PATH '$.abn_status_cd', health_plan_id VARCHAR2(4000) PATH '$.health_plan_id', fin_class_cd VARCHAR2(4000) PATH '$.fin_class_cd', item_interval_id VARCHAR2(4000) PATH '$.item_interval_id', item_list_price VARCHAR2(4000) PATH '$.item_list_price', item_reimbursement VARCHAR2(4000) PATH '$.item_reimbursement', list_price_sched_id VARCHAR2(4000) PATH '$.list_price_sched_id', payor_type_cd VARCHAR2(4000) PATH '$.payor_type_cd', epsdt_ind VARCHAR2(4000) PATH '$.epsdt_ind', ref_phys_id VARCHAR2(4000) PATH '$.ref_phys_id', start_dt_tm VARCHAR2(4000) PATH '$.start_dt_tm', stop_dt_tm VARCHAR2(4000) PATH '$.stop_dt_tm', alpha_nomen_id VARCHAR2(4000) PATH '$.alpha_nomen_id', server_process_flag VARCHAR2(4000) PATH '$.server_process_flag', item_deductible_amt VARCHAR2(4000) PATH '$.item_deductible_amt', patient_responsibility_flag VARCHAR2(4000) PATH '$.patient_responsibility_flag', offset_charge_item_id VARCHAR2(4000) PATH '$.offset_charge_item_id', cs_cpp_undo_id VARCHAR2(4000) PATH '$.cs_cpp_undo_id', cs_cpp_undo_qual_id VARCHAR2(4000) PATH '$.cs_cpp_undo_qual_id', posted_id VARCHAR2(4000) PATH '$.posted_id', pricing_status_cd VARCHAR2(4000) PATH '$.pricing_status_cd', activity_sub_type_cd VARCHAR2(4000) PATH '$.activity_sub_type_cd', provider_specialty_cd VARCHAR2(4000) PATH '$.provider_specialty_cd', last_utc_ts VARCHAR2(4000) PATH '$.last_utc_ts', inst_id VARCHAR2(4000) PATH '$.inst_id', original_org_id VARCHAR2(4000) PATH '$.original_org_id', txn_id_text VARCHAR2(4000) PATH '$.txn_id_text', original_encntr_id VARCHAR2(4000) PATH '$.original_encntr_id', service_interface_flag VARCHAR2(4000) PATH '$.service_interface_flag', item_price_adj_amt VARCHAR2(4000) PATH '$.item_price_adj_amt'
        )
    )
)
select * from charge c
join pipeline_get_charges gc on
gc.charge_item_id = c.charge_item_id]
(Background on this error at: https://sqlalche.me/e/20/4xp6)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/worker/shared/logging/ps_logging.py", line 368, in run_step_error
    gql_sync_client.execute(
  File "/usr/local/lib/python3.12/site-packages/gql/client.py", line 484, in execute
    return self.execute_sync(
           ^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/gql/client.py", line 248, in execute_sync
    return session.execute(
           ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/site-packages/gql/client.py", line 1028, in execute
    raise TransportQueryError(
gql.transport.exceptions.TransportQueryError: {'message': 'payload string too long', 'extensions': {'path': '$', 'code': 'data-exception'}}