updated Services (Write)
This commit is contained in:
parent
15a8b86823
commit
558de2399f
|
|
@ -22,7 +22,6 @@ def update_parsed_data_to_mongo_database(mongo_provider, collected_data_dict: di
|
||||||
if collected_data_dict:
|
if collected_data_dict:
|
||||||
payload = collected_data_dict[filename]
|
payload = collected_data_dict[filename]
|
||||||
if payload:
|
if payload:
|
||||||
print('filename, payload', filename, payload)
|
|
||||||
mongo_provider.update_one(
|
mongo_provider.update_one(
|
||||||
filter_query={"filename": filename},
|
filter_query={"filename": filename},
|
||||||
update_data={"$set": {"parsed": payload, "stage": "parsed"}},
|
update_data={"$set": {"parsed": payload, "stage": "parsed"}},
|
||||||
|
|
@ -73,7 +72,6 @@ def app():
|
||||||
)
|
)
|
||||||
results = collect_excel_files_from_mongo_database(mongo_provider)
|
results = collect_excel_files_from_mongo_database(mongo_provider)
|
||||||
if not results:
|
if not results:
|
||||||
print("No results found.")
|
|
||||||
return
|
return
|
||||||
|
|
||||||
for result in results:
|
for result in results:
|
||||||
|
|
|
||||||
|
|
@ -49,7 +49,7 @@ def write_parsed_data_to_account_records(
|
||||||
new_account_record.save(db=db_session)
|
new_account_record.save(db=db_session)
|
||||||
mongo_provider.update_one(
|
mongo_provider.update_one(
|
||||||
filter_query={"filename": file},
|
filter_query={"filename": file},
|
||||||
update_data={"$set": {"stage": "completed"}},
|
update_data={"$set": {"stage": "written"}},
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue