We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4869482 commit cee39a0Copy full SHA for cee39a0
src/dve/pipeline/foundry_ddb_pipeline.py
@@ -126,6 +126,8 @@ def run_pipeline(
126
report_uri = None
127
if self._submitted_files_path:
128
self._move_submission_to_processing_files_path(submission_info)
129
+ self._audit_tables.add_new_submissions(submissions=[submission_info])
130
+ self._audit_tables.mark_transform(submission_ids=[sub_id])
131
sub_info, sub_status = self.file_transformation(submission_info=submission_info)
132
if not (sub_status.validation_failed or sub_status.processing_failed):
133
self._audit_tables.mark_data_contract(submission_ids=[sub_id])
0 commit comments