AVRO_updates.

adsabs · May 26, 2023 · e0ac19e · e0ac19e
1 parent 8ee297e
commit e0ac19e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/SciXHarvester/API/harvester_server.py b/SciXHarvester/API/harvester_server.py
@@ -156,13 +156,14 @@ def persistent_connection(self, job_request, listener):
 
     def initHarvester(self, request, context: grpc.aio.ServicerContext):
         self.logger.info("Serving initHarvester request %s", request)
+        tstamp = datetime.now().timestamp()
         self.logger.info(json.dumps(request.get("task_args")))
         self.logger.info(
             "Sending {} to Harvester Topic".format(
                 b" %s." % json.dumps(request.get("task_args")).encode("utf-8")
             )
         )
-        hash = hashlib.sha256(bytes(str(request), "utf-8")).hexdigest()
+        hash = hashlib.sha256(bytes(str(request) + str(tstamp), "utf-8")).hexdigest()
         self.logger.info("{}".format(hash))
 
         job_request = request