Skip to content
4 changes: 4 additions & 0 deletions app/airflow/dags/libs/SR_processing/db_services.py
Original file line number Diff line number Diff line change
Expand Up @@ -124,6 +124,8 @@ def update_temp_data_dictionary_table(
"value",
"value_description",
],
fast_executemany=True,
commit_every=0, # commit every row to avoid transaction overhead
Comment thread
AndyRae marked this conversation as resolved.
Outdated
)

logging.info(
Expand Down Expand Up @@ -211,6 +213,8 @@ def create_temp_field_values_table(
"value",
"frequency",
],
fast_executemany=True,
commit_every=0, # commit every row to avoid transaction overhead
)

except Exception as e:
Expand Down
Loading