diff --git a/app/services/submit_envelope_download_workflow.rb b/app/services/submit_envelope_download_workflow.rb index 24edd89a..e45e24b3 100644 --- a/app/services/submit_envelope_download_workflow.rb +++ b/app/services/submit_envelope_download_workflow.rb @@ -72,6 +72,7 @@ def parameters 'destination-bucket' => ENV.fetch('ENVELOPE_DOWNLOADS_BUCKET'), 'destination-prefix' => destination_prefix, 'environment' => MR.env, + 'max-input-files' => ENV.fetch('ARGO_WORKFLOWS_MAX_INPUT_FILES', '1'), 'max-uncompressed-zip-size-bytes' => ENV.fetch( 'ARGO_WORKFLOWS_MAX_UNCOMPRESSED_ZIP_SIZE_BYTES', (200 * 1024 * 1024).to_s diff --git a/spec/services/submit_envelope_download_workflow_spec.rb b/spec/services/submit_envelope_download_workflow_spec.rb index b86200ee..773e3859 100644 --- a/spec/services/submit_envelope_download_workflow_spec.rb +++ b/spec/services/submit_envelope_download_workflow_spec.rb @@ -12,6 +12,7 @@ allow(ENV).to receive(:fetch).and_call_original allow(ENV).to receive(:fetch).with('ARGO_WORKFLOWS_TASK_IMAGE').and_return('registry:s3-graphs-zip') allow(ENV).to receive(:fetch).with('ARGO_WORKFLOWS_BATCH_SIZE', '25000').and_return('25000') + allow(ENV).to receive(:fetch).with('ARGO_WORKFLOWS_MAX_INPUT_FILES', '1').and_return('1') allow(ENV).to receive(:fetch) .with('ARGO_WORKFLOWS_MAX_UNCOMPRESSED_ZIP_SIZE_BYTES', '209715200') .and_return('209715200') @@ -32,6 +33,7 @@ 'destination-bucket' => 'downloads-bucket', 'destination-prefix' => "ce_registry/downloads/#{envelope_download.id}", 'environment' => MR.env, + 'max-input-files' => '1', 'max-uncompressed-zip-size-bytes' => '209715200', 'max-workers' => '4', 'source-bucket' => 'graphs-bucket',