self = <swh.scheduler.tests.test_scheduler.TestScheduler object at 0x7fd39d1366a0>
swh_scheduler = <swh.scheduler.backend.SchedulerBackend object at 0x7fd39d136a90>
def test_peek_ready_tasks_returns_only_no_priority_tasks(self, swh_scheduler):
"""Peek ready tasks only return standard tasks (no priority)"""
self._create_task_types(swh_scheduler)
t = utcnow()
task_type = TEMPLATES["git"]["type"]
# Create tasks with and without priorities
tasks = tasks_from_template(
TEMPLATES["git"], t, num_priorities=NUM_PRIORITY_TASKS,
)
count_priority = 0
for task in tasks:
count_priority += 0 if task.get("priority") is None else 1
assert count_priority > 0, "Some created tasks should have some priority"
random.shuffle(tasks)
> swh_scheduler.create_tasks(tasks)
.tox/py3/lib/python3.7/site-packages/swh/scheduler/tests/test_scheduler.py:213:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.tox/py3/lib/python3.7/site-packages/swh/core/db/common.py:62: in _meth
return meth(self, *args, db=db, cur=cur, **kwargs)
.tox/py3/lib/python3.7/site-packages/swh/scheduler/backend.py:506: in create_tasks
cur.execute("select swh_scheduler_mktemp_task()")
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <cursor object at 0x7fd39d29fe48; closed: -1>
query = 'select swh_scheduler_mktemp_task()', vars = None
def execute(self, query, vars=None):
self.column_mapping = []
self._query_executed = True
> return super().execute(query, vars)
E psycopg2.errors.UndefinedFunction: function swh_scheduler_mktemp_task() does not exist
E LINE 1: select swh_scheduler_mktemp_task()
E ^
E HINT: No function matches the given name and argument types. You might need to add explicit type casts.
.tox/py3/lib/python3.7/site-packages/psycopg2/extras.py:236: UndefinedFunction
TEST RESULT
TEST RESULT
- Run At
- Jun 23 2021, 6:13 PM