Compare commits

..

10 Commits

7 changed files with 8 additions and 4 deletions

Binary file not shown.

View File

@@ -1135,8 +1135,9 @@ def _process_inclusion_data(inclusion, organization):
output_inclusion = {}
# --- Prepare all data sources ---
# 1. 6-month visit loading disabled on this branch (No-6-Month-Visit)
# visit_future = subtasks_thread_pool.submit(run_with_context, search_visit_by_pseudo_and_order, ctx, pseudo, 2)
# 1. Launch Visit Search asynchronously (it's slow, ~5s)
# We use run_with_context to pass the patient identity to the new thread
visit_future = subtasks_thread_pool.submit(run_with_context, search_visit_by_pseudo_and_order, ctx, pseudo, 2)
# 2. Prepare inclusion_data: enrich inclusion with organization info
inclusion_data = dict(inclusion)
@@ -1160,8 +1161,11 @@ def _process_inclusion_data(inclusion, organization):
logging.error(f"Error fetching request data for patient {patient_id}: {e}")
request_data = None
# 6-month visit loading disabled on this branch (No-6-Month-Visit)
six_month_visit_data = None
try:
six_month_visit_data = visit_future.result()
except Exception as e:
logging.error(f"Error searching 6-month visit for patient {pseudo}: {e}")
six_month_visit_data = None
# --- Process all fields from configuration ---
process_inclusions_mapping(output_inclusion, inclusion_data, record_data, request_data, all_questionnaires, six_month_visit_data)