DMC/play-daemon
13
1
Fork 0
Code Issues 2 Pull Requests Releases Wiki Activity

Fixes #5 #6

Merged
dafo5502 merged 5 commits from developer into master 2021-10-27 09:59:42 +02:00
Conversation 1 Commits 5 Files Changed 3 +2
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit ec549a99b4 - Show all commits

1
daemon/__init__.py
View File

@ -52,6 +52,7 @@ class Daemon:
except Exception as e: except Exception as e:
msg = "Exception during processing of queue item %s: %s" msg = "Exception during processing of queue item %s: %s"
self.logger.exception(msg, pres_id, queue_item, exc_info=e) self.logger.exception(msg, pres_id, queue_item, exc_info=e)
# write the que info and error to disk for play-api to display the status
with open(os.path.join(self.error_dir, pres_id), 'w') as f: with open(os.path.join(self.error_dir, pres_id), 'w') as f:
queue_item['error'] = e queue_item['error'] = e
json.dump(queue_item, f) json.dump(queue_item, f)

1
daemon/pipeline.py
View File

@ -170,6 +170,7 @@ class Pipeline:
# Delete queue file and upload data # Delete queue file and upload data
os.remove(os.path.join(self.queue, target_id)) os.remove(os.path.join(self.queue, target_id))
try: try:
# if any old error file remove it since now iot has worked
os.remove(os.path.join(self.error, target_id)) os.remove(os.path.join(self.error, target_id))
except OSError: except OSError:
pass pass