diff --git a/nmdc_automation/import_automation/activity_mapper.py b/nmdc_automation/import_automation/activity_mapper.py index b162c41f..fe712bf4 100644 --- a/nmdc_automation/import_automation/activity_mapper.py +++ b/nmdc_automation/import_automation/activity_mapper.py @@ -200,6 +200,7 @@ def process_files(files: Union[str, List[str]], data_object_dict: Dict, workflow # Process unique data objects if unique: for file in map(str, self.project_files): + logger.info(f"Processing file {file}") if re.search(data_object_spec["import_suffix"], file): workflow_execution_id = self.get_workflow_execution_id(data_object_spec["output_of"]) db.data_object_set.append(process_files(file, data_object_spec, workflow_execution_id)) @@ -242,6 +243,8 @@ def map_workflow_executions(self, db) -> nmdc.Database: logging.error( f"Skipping {workflow['Name']} due to missing inputs or outputs" ) + logger.error(f"Inputs: {has_inputs_list}") + logger.error(f"Outputs: {has_output_list}") continue # Mint an ID if needed wf_id = self.workflow_execution_ids.get(workflow["Type"], None)