search

alexhsamuel / apsis

General-purpose scheduler.
Other
3 stars 3 forks source link

exception after skip waiting run #285

Closed alexhsamuel closed 1 year ago

alexhsamuel commented 1 year ago 
2023-07-07T18:43:28.367 apsis.apsis              I canceling waiting for r83842 waiting test/dep/dep1(foo=as label=qw) task
2023-07-07T18:43:28.368 asyncio                  E Exception in callback <function Apsis.__wait.<locals>.<lambda> at 0x7f8a73e170a0>
handle: <Handle Apsis.__wait.<locals>.<lambda> created at /home/alex/dev/apsis/python/apsis/service/main.py:189>
source_traceback: Object created at (most recent call last):
  File "/home/alex/dev/apsis/env/bin/apsisctl", line 8, in <module>
    sys.exit(main())
  File "/home/alex/dev/apsis/python/apsis/ctl.py", line 214, in main
    status = args.cmd(args)
  File "/home/alex/dev/apsis/python/apsis/ctl.py", line 147, in cmd_serve
    restart = apsis.service.main.serve(
  File "/home/alex/dev/apsis/python/apsis/service/main.py", line 189, in serve
    loop.run_forever()
Traceback (most recent call last):
  File "uvloop/cbhandles.pyx", line 63, in uvloop.loop.Handle._run
  File "/home/alex/dev/apsis/python/apsis/apsis.py", line 232, in <lambda>
    task.add_done_callback(lambda _: self.__wait_tasks.pop(run))
KeyError: Run('r83842', Instance('test/dep/dep1', {'foo': 'as', 'label': 'qw'}), state=<Run.STATE.waiting: 3>)
2023-07-07T18:43:28.368 apsis.apsis              I waiting for r83842 waiting test/dep/dep1(foo=as label=qw) task cancelled
2023-07-07T18:43:28.368 apsis.run_log            I r83842: skipped
2023-07-07T18:43:28.379 sanic.access             I 200 POST http://localhost:5000/api/v1/runs/r83842/skip (127.0.0.1:52594)