Skip to content

Commit d534ca9

Browse files
committed
added flush to see sturdy refs in slurm output
1 parent ede1a07 commit d534ca9

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

zalfmas_common/service.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ async def heartbeat():
244244
await hb.beat()
245245

246246
admin.tasks.append(asyncio.create_task(heartbeat()))
247-
print(f"service: {name}, sr@'{gw['name']}': {common.sturdy_ref_str_from_sr(service_sr_at_gateway)}")
247+
print(f"service: {name}, sr@'{gw['name']}': {common.sturdy_ref_str_from_sr(service_sr_at_gateway)}", flush=True)
248248
else:
249249
print("Couldn't connect to gateway at sturdy_ref:", sr)
250250
except Exception as e:
@@ -332,8 +332,8 @@ async def new_connection(stream):
332332
cap=s, fixed_sr_token=name_to_service_srs.get(name, None)
333333
)
334334
name_to_service_srs[name] = res["sturdy_ref"]
335-
print("service:", name, "sr:", res["sturdy_ref"])
336-
print("restorer_sr:", restorer.sturdy_ref_str())
335+
print("service:", name, "sr:", res["sturdy_ref"], flush=True)
336+
print("restorer_sr:", restorer.sturdy_ref_str(), flush=True)
337337

338338
await register_services(con_man, name_to_service, admin, registries)
339339
await register_vat_at_resolvers(con_man, resolvers, admin)

0 commit comments

Comments
 (0)