Skip to content

Commit

Permalink
Merge pull request #4982 from bcgov/test-marshal-DV-4707-1
Browse files Browse the repository at this point in the history
removed logs
  • Loading branch information
divyav-aot authored Jan 9, 2024
2 parents 4054e4e + 5fbf2cb commit ee34250
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions request-management-api/request_api/services/recordservice.py
Original file line number Diff line number Diff line change
Expand Up @@ -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.")
Expand All @@ -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,
Expand Down

0 comments on commit ee34250

Please sign in to comment.