Skip to content

Commit cbc86f0

Browse files
authored
Set threads and skip all providers file (#329)
2 parents c7ab436 + ca9d5d3 commit cbc86f0

File tree

3 files changed

+9
-7
lines changed

3 files changed

+9
-7
lines changed

app/services/language_content_processor.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,11 +25,11 @@ def provider_files
2525
# this is needed to avoid loading all files into memory at once
2626
def language_files
2727
{
28-
all_providers: FileToUpload.new(
29-
content: ->(language) { XmlGenerator::AllProviders.new(language).perform },
30-
name: "#{language.file_storage_prefix}Server_XML.xml",
31-
path: "#{language.file_storage_prefix}CMES-Pi/assets/XML",
32-
),
28+
# all_providers: FileToUpload.new(
29+
# content: ->(language) { XmlGenerator::AllProviders.new(language).perform },
30+
# name: "#{language.file_storage_prefix}Server_XML.xml",
31+
# path: "#{language.file_storage_prefix}CMES-Pi/assets/XML",
32+
# ),
3333
all_providers_recent: FileToUpload.new(
3434
content: ->(language) { XmlGenerator::AllProviders.new(language, recent: true).perform },
3535
name: "#{language.file_storage_prefix}New_Uploads_Server_XML.xml",

config/deploy.staging.yml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,8 @@ env:
3434
AWS_ENDPOINT_URL: "" # Empty for real AWS
3535
LOCALSTACK_DEBUG: "0"
3636
S3_SKIP_SIGNATURE_VALIDATION: "0"
37+
RAILS_MAX_THREADS: 5
38+
WEB_CONCURRENCY: 2
3739
SOLID_QUEUE_IN_PUMA: true
3840
DATA_IMPORT_SOURCE: azure
3941

spec/services/language_content_processor_spec.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,12 @@
1515
end
1616

1717
it "processes content for every language" do
18-
files_number = language.providers.size + 9 # 2 xml files for all provides, 2 text files for tags, 5 csv files
18+
files_number = language.providers.size + 8 # 2 xml files for all provides, 2 text files for tags, 5 csv files
1919
subject.perform
2020

2121
expect(FileUploadJob).to have_received(:perform_later).exactly(files_number).times
2222

23-
expect(FileUploadJob).to have_received(:perform_later).with(language.id, "all_providers")
23+
# expect(FileUploadJob).to have_received(:perform_later).with(language.id, "all_providers")
2424
expect(FileUploadJob).to have_received(:perform_later).with(language.id, "all_providers_recent")
2525
expect(FileUploadJob).to have_received(:perform_later).with(language.id, "tags")
2626
expect(FileUploadJob).to have_received(:perform_later).with(language.id, "tags_and_title")

0 commit comments

Comments
 (0)