Fix nesting of futures

ooni · Sep 4, 2024 · 1e50f68 · 1e50f68
1 parent 9bf3040
commit 1e50f68
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/oonipipeline/src/oonipipeline/temporal/activities/observations.py b/oonipipeline/src/oonipipeline/temporal/activities/observations.py
@@ -231,7 +231,7 @@ async def make_observations(params: MakeObservationsParams) -> MakeObservationsR
                     executor=process_pool,
                 )
             )
-    measurement_count = sum(await asyncio.gather(*awaitables))
+        measurement_count = sum(await asyncio.gather(*awaitables))
 
     current_span.set_attribute("total_runtime_ms", tbatch.ms)
     # current_span.set_attribute("total_failure_count", total_failure_count)