Skip to content

Commit

Permalink
deal with skipped pf with no output_wfr
Browse files Browse the repository at this point in the history
  • Loading branch information
aschroed committed Aug 8, 2024
1 parent c084fb9 commit ee57d6c
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions functions/cleanup.py
Original file line number Diff line number Diff line change
Expand Up @@ -135,12 +135,13 @@ def delete_wfrs(file_resp, my_key, workflow_details, delete=False, stash=None):
# do not delete output wfrs of control files
output_wfrs = file_resp.get('workflow_run_outputs')
if not output_wfrs:
if file_type == 'files-processed':
# user submtted processed files
return
else:
#if file_type == 'files-processed':
# user submtted processed files but we still want to see if there is an associated errored wfr
# return
# continue
#else:
# raw files:
pass
pass
else:
output_wfr = output_wfrs[0]
wfr_type, _ = output_wfr['display_title'].split(' run ')
Expand All @@ -151,8 +152,6 @@ def delete_wfrs(file_resp, my_key, workflow_details, delete=False, stash=None):
wfr_uuids = [i['uuid'] for i in file_resp.get('workflow_run_inputs')]
wfrs = []
if wfr_uuids:
if '15700187-3843-4062-95ff-57c8ac913a1d' in wfr_uuids:
print("WE HAVE THE PROBLEM HERE")
# fetch them from stash
if stash:
wfrs = [i for i in stash if i['uuid'] in wfr_uuids]
Expand Down

0 comments on commit ee57d6c

Please sign in to comment.