Includes Reshuffle

google · Mar 21, 2024 · c789ceb · c789ceb
1 parent 17ae398
commit c789ceb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/megalista_dataflow/steps/processing_steps.py b/megalista_dataflow/steps/processing_steps.py
@@ -523,6 +523,7 @@ def expand(self, executions):
                 10000,
                 TransactionalType.UUID,
             )
+            | "Reshuffle" >> beam.Reshuffle()
             | "Upload - GA 4 measurement protocol"
             >> beam.ParDo(
                 GoogleAnalytics4MeasurementProtocolUploaderDoFn(