record the collection time to match when the aggregations are being queried for (#216)

jobs/dap-collector-ppa-dev/dap_collector_ppa_dev/main.py

@@ -101,7 +101,7 @@ async def collect_once(task, timestamp, duration, hpke_private_key, auth_token):
         res["reports"].append(rpt)
         return res
 
-    print(f"{collection_time} Result: code {proc.returncode}")
+    print(f"{timestamp} Result: code {proc.returncode}")
     rpt["collection_duration"] = time.perf_counter() - start_counter
 
     # Parse the output of the collect binary
@@ -126,7 +126,7 @@ async def collect_once(task, timestamp, duration, hpke_private_key, auth_token):
                     print(task["task_id"], i, ad)
                     if ad is not None:
                         cnt = {}
-                        cnt["collection_time"] = collection_time
+                        cnt["collection_time"] = timestamp
                         cnt["placement_id"] = ad["advertiserInfo"]["placementId"]
                         cnt["advertiser_id"] = ad["advertiserInfo"]["advertiserId"]
                         cnt["advertiser_name"] = ad["advertiserInfo"]["advertiserName"]