blepabyte / canvasfs Goto Github PK

(Fix) either:

• Use some sort of async multi-consumer channel that signals get passed through
  

  canvasfs/canvasfs.py

  Lines 103 to 108 in 70931c6

  	while True:
  	# Wait for first of either refresh interval elapsing or manual user intervention
  	with trio.open_signal_receiver(signal.SIGUSR1) as signal_aiter:
  	await trio_race(
  	signal_aiter.__anext__,
  	(await trio.sleep(interval * 60 * 60) for _ in [None]).__anext__

• Separate async task spawned in main nursery that handles the signal and calls build function on courses individually
  

  canvasfs/canvasfs.py

  Lines 379 to 383 in 70931c6

  	async with trio.open_nursery() as nursery:
  	nursery.start_soon(pyfuse3.main)
  	for _, sub in root_fs:
  	nursery.start_soon(sub.poll)