YunoHost/yunorunner
1
0
Fork 0
mirror of https://github.com/YunoHost/yunorunner.git synced 2024-09-03 20:05:52 +02:00
Code Issues Projects Releases Packages Wiki Activity

[mod] identation

Browse source
This commit is contained in:
Laurent Peuch 2018-07-15 04:08:00 +02:00
parent 517877b74f
commit 136c2825df
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
run.py
View file

@ -115,9 +115,9 @@ async def jobs_dispatcher():
async def run_job(worker, job): async def run_job(worker, job):
await broadcast({ await broadcast({
"action": "update_job", "action": "update_job",
"data": model_to_dict(job), "data": model_to_dict(job),
}, ["jobs", f"job-{job.id}"]) }, ["jobs", f"job-{job.id}"])
# fake stupid command, whould run CI instead # fake stupid command, whould run CI instead
print(f"Starting job {job.name}...") print(f"Starting job {job.name}...")
@ -136,10 +136,10 @@ async def run_job(worker, job):
job.save() job.save()
await broadcast({ await broadcast({
"action": "update_job", "action": "update_job",
"id": job.id, "id": job.id,
"data": model_to_dict(job), "data": model_to_dict(job),
}, ["jobs", f"job-{job.id}"]) }, ["jobs", f"job-{job.id}"])
print(f">> {line}") print(f">> {line}")
@ -157,10 +157,10 @@ async def run_job(worker, job):
worker.save() worker.save()
await broadcast({ await broadcast({
"action": "update_job", "action": "update_job",
"id": job.id, "id": job.id,
"data": model_to_dict(job), "data": model_to_dict(job),
}, ["jobs", f"job-{job.id}"]) }, ["jobs", f"job-{job.id}"])
async def broadcast(message, channels): async def broadcast(message, channels):