Skip to content

Commit 5a0de4a

Browse files
committed
Log job creation and completion at INFO
1 parent ad5d4ba commit 5a0de4a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

mqterm/terminal.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ async def update_job(self, client_id, seq, payload):
104104
cmd = payload.decode("utf-8")
105105
job = Job.from_cmd(cmd, client_id=client_id)
106106
self.jobs[client_id] = job
107-
self.logger.debug(f"Created {job}")
107+
self.logger.info(f"Created {job}")
108108

109109
# Run the job if it's ready and stream the results / signal completion
110110
if job.ready:
@@ -115,6 +115,7 @@ async def update_job(self, client_id, seq, payload):
115115
qos=1,
116116
properties=format_properties(client_id, -1),
117117
)
118+
self.logger.info(f"Completed {job}")
118119
del self.jobs[client_id]
119120

120121
async def stream_job_output(self, job):

0 commit comments

Comments
 (0)