There was an error while loading. Please reload this page.
1 parent 8494f21 commit cfbac32Copy full SHA for cfbac32
1 file changed
app/airflow/dags/libs/SR_processing/db_services.py
@@ -125,7 +125,7 @@ def update_temp_data_dictionary_table(
125
"value_description",
126
],
127
fast_executemany=True,
128
- commit_every=0, # commit every row to avoid transaction overhead
+ commit_every=10000, # commit every 10k
129
)
130
131
logging.info(
@@ -214,7 +214,7 @@ def create_temp_field_values_table(
214
"frequency",
215
216
217
218
219
220
except Exception as e:
0 commit comments