From d6a974d8114373feb412edbc7215b8c9a57e0431 Mon Sep 17 00:00:00 2001 From: divyav-aot Date: Tue, 9 Jan 2024 11:26:49 -0500 Subject: [PATCH] removed logs --- .../request_api/services/recordservice.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/request-management-api/request_api/services/recordservice.py b/request-management-api/request_api/services/recordservice.py index eda12999a..45a11662a 100644 --- a/request-management-api/request_api/services/recordservice.py +++ b/request-management-api/request_api/services/recordservice.py @@ -218,12 +218,9 @@ def __triggerpdfstitchservice(self, requestid, ministryrequestid, message, useri "attributes": json.JSONEncoder().encode(message["attributes"]), "totalfilesize": message["totalfilesize"] } - print("final message >>>>>> ", streamobject) if message["totalfilesize"] > int(self.stitchinglargefilesizelimit) and self.pdfstitchstreamkey_largefiles: - print("pdfstitchstreamkey_largefiles = ", self.pdfstitchstreamkey_largefiles) return eventqueueservice().add(self.pdfstitchstreamkey_largefiles, streamobject) elif self.pdfstitchstreamkey: - print("pdfstitchstreamkey = ", self.pdfstitchstreamkey) return eventqueueservice().add(self.pdfstitchstreamkey, streamobject) else: print("pdfstitch stream key is missing. Message is not pushed to the stream.") @@ -249,8 +246,7 @@ def __bulkcreate(self, requestid, ministryrequestid, records, userid): if (dbresponse.success): #processingrecords = [{**record, **{"recordid": dbresponse.args[0][record['s3uripath']]['recordid']}} for record in records if not record['attributes'].get('incompatible', False)] processingrecords = [{**record, **{"recordid": dbresponse.args[0][record['s3uripath']]['recordid']}} for record in records] - - print(processingrecords) + # record all jobs before sending first redis stream message to avoid race condition jobids, err = self.makedocreviewerrequest('POST', '/api/jobstatus', { 'records': processingrecords,