Add missing continue

elastic · Jan 30, 2023 · a9c0ce7 · a9c0ce7
1 parent d255780
commit a9c0ce7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/esrally/track/params.py b/esrally/track/params.py
@@ -970,6 +970,7 @@ def create_readers(
                     end_client_index,
                     corpus.name,
                 )
+                continue
 
             target = f"{docs.target_index}/{docs.target_type}" if docs.target_index else "/"
             if docs.target_data_stream:

diff --git a/tests/track/params_test.py b/tests/track/params_test.py
@@ -1391,7 +1391,13 @@ def test_generate_bulks_from_multiple_corpora(self):
                         number_of_documents=5,
                         target_index="logs-2017-01",
                         target_type="docs",
-                    )
+                    ),
+                    track.Documents(
+                        source_format=track.Documents.SOURCE_FORMAT_BULK,
+                        number_of_documents=0,
+                        target_index="logs-2017-02",
+                        target_type="docs",
+                    ),
                 ],
             ),
             track.DocumentCorpus(