swh_sched = <swh.scheduler.backend.SchedulerBackend object at 0x7fd39d0ec710>
swh_sched_config_file = '/tmp/pytest-of-jenkins/pytest-0/test_cli_archive_tasks0/elastic.yml'
@pytest.mark.usefixtures("swh_elasticsearch_backend")
def test_cli_archive_tasks(swh_sched, swh_sched_config_file):
scheduler = swh_sched
template_git = TEMPLATES["git"]
template_hg = TEMPLATES["hg"]
# first initialize scheduler's db (is this still needed?)
for tt in TASK_TYPES.values():
scheduler.create_task_type(tt)
next_run_start = utcnow() - datetime.timedelta(days=1)
recurring = tasks_from_template(template_git, next_run_start, 100)
oneshots = tasks_from_template(
template_hg, next_run_start - datetime.timedelta(days=1), 50
)
past_time = next_run_start - datetime.timedelta(days=7)
all_tasks = recurring + oneshots
> result = scheduler.create_tasks(all_tasks)
.tox/py3/lib/python3.7/site-packages/swh/scheduler/tests/es/test_cli_task.py:41:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.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 0x7fd39d122c48; 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