Skip to content

Commit

Permalink
foo
Browse files Browse the repository at this point in the history
  • Loading branch information
sambles committed Jan 30, 2025
1 parent 9e3b80a commit 2e295ec
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions src/model_execution_worker/distributed_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -378,7 +378,6 @@ def _prepare_directories(params, analysis_id, run_data_uuid, kwargs):
if filestore.storage_connector == 'FS-SHARE':
Path(filestore.root_dir, params['storage_subdir']).mkdir(parents=True, exist_ok=True)


# Set `oasis-file-generation` input files
params.setdefault('target_dir', params['root_run_dir'])
params.setdefault('user_data_dir', os.path.join(params['root_run_dir'], 'user-data'))
Expand Down Expand Up @@ -517,28 +516,28 @@ def pre_analysis_hook(self,
pre_loc_fp = os.path.join(hook_target_dir, files_modified.get('location'))
params['pre_loc_file'] = filestore.put(
pre_loc_fp,
#filename=os.path.basename(pre_loc_fp),
# filename=os.path.basename(pre_loc_fp),
subdir=params['storage_subdir']
)
if files_modified.get('account'):
pre_acc_fp = os.path.join(hook_target_dir, files_modified.get('account'))
params['pre_acc_file'] = filestore.put(
pre_acc_fp,
#filename=os.path.basename(pre_acc_fp),
# filename=os.path.basename(pre_acc_fp),
subdir=params['storage_subdir']
)
if files_modified.get('ri_info'):
pre_info_fp = os.path.join(hook_target_dir, files_modified.get('ri_info'))
params['pre_info_file'] = filestore.put(
pre_info_fp,
#filename=os.path.basename(pre_info_fp),
# filename=os.path.basename(pre_info_fp),
subdir=params['storage_subdir']
)
if files_modified.get('ri_scope'):
pre_scope_fp = os.path.join(hook_target_dir, files_modified.get('ri_scope'))
params['pre_scope_file'] = filestore.put(
pre_scope_fp,
#filename=os.path.basename(pre_scope_fp),
# filename=os.path.basename(pre_scope_fp),
subdir=params['storage_subdir']
)

Expand Down

0 comments on commit 2e295ec

Please sign in to comment.