async with asyncio.TaskGroup() as tg:
for job in jobs:
- task = tg.create_task(job.depcheck())
+ task = tg.create_task(job.installcheck())
tasks.append(task)
# Try to dispatch any jobs afterwards if at least one task returned True
AND
jobs.finished_at IS NULL
AND
- jobs.depcheck_succeeded IS TRUE
+ jobs.installcheck_succeeded IS TRUE
ORDER BY
_rank
""")
"""
return self.build.build_repo.pakfire(arch=self.arch, **kwargs)
- async def depcheck(self):
+ async def installcheck(self):
"""
- Perform dependency check
+ Perform install check
"""
return await self.build.build_repo.installcheck([self])
# Store any dependency errors
except DependencyError as e:
- self._set_attribute("depcheck_succeeded", False)
+ self._set_attribute("installcheck_succeeded", False)
# Store the message
self._set_attribute("message", "%s" % e)
# Everything OK
else:
- self._set_attribute("depcheck_succeeded", True)
+ self._set_attribute("installcheck_succeeded", True)
# Store the timestamp
- self._set_attribute_now("depcheck_performed_at")
+ self._set_attribute_now("installcheck_performed_at")
# Return the status
- return self.depcheck_succeeded
+ return self.installcheck_succeeded
@property
- def depcheck_succeeded(self):
- return self.data.depcheck_succeeded
+ def installcheck_succeeded(self):
+ return self.data.installcheck_succeeded
@property
- def depcheck_performed_at(self):
- return self.data.depcheck_performed_at
+ def installcheck_performed_at(self):
+ return self.data.installcheck_performed_at
# Reverse Requires
builder_id integer,
message text,
superseeded_by integer,
- depcheck_succeeded boolean,
- depcheck_performed_at timestamp without time zone,
+ installcheck_succeeded boolean,
+ installcheck_performed_at timestamp without time zone,
failed boolean DEFAULT false NOT NULL,
log_path text,
log_size bigint,
-- Name: jobs_pending; Type: INDEX; Schema: public; Owner: -
--
-CREATE INDEX jobs_pending ON public.jobs USING btree (id) WHERE ((deleted_at IS NULL) AND (started_at IS NULL) AND (finished_at IS NULL) AND (depcheck_succeeded IS TRUE));
+CREATE INDEX jobs_pending ON public.jobs USING btree (id) WHERE ((deleted_at IS NULL) AND (started_at IS NULL) AND (finished_at IS NULL) AND (installcheck_succeeded IS TRUE));
--
"cleanup" : self.backend.cleanup,
# Jobs
- "jobs:depcheck" : self._jobs_depcheck,
+ "jobs:installcheck" : self._jobs_installcheck,
# Keys
"keys:generate" : self.backend.keys.generate,
# Exit with error code
sys.exit(r or 0)
- async def _jobs_depcheck(self, *uuids):
+ async def _jobs_installcheck(self, *uuids):
"""
- Test command to trigger a dependency check
+ Test command to trigger a installcheck check
"""
jobs = []
# Run the checks
for job in jobs:
- await job.depcheck()
+ await job.installcheck()
def _list_repository(self, distro_name, repo_name, arch):
# Get distribution
<div class="block">
<article class="panel
- {% if job.is_pending() and job.depcheck_succeeded is False %}
+ {% if job.is_pending() and job.installcheck_succeeded is False %}
is-warning
{% elif job.is_aborted() %}
is-dark
</div>
<div class="level-right">
- {% if job.is_pending() and job.depcheck_succeeded is False %}
+ {% if job.is_pending() and job.installcheck_succeeded is False %}
<span class="tag">{{ _("Dependency Problems") }}</span>
{% elif job.is_pending() %}
<span class="tag">{{ _("Pending") }}</span>
</div>
{# Dependency Issues #}
- {% elif job.is_pending() and job.depcheck_succeeded is False %}
+ {% elif job.is_pending() and job.installcheck_succeeded is False %}
<div class="panel-block">
<ul>
{% for line in job.message.splitlines() %}
# has not been finished, yet
self.assertEqual(len(self.backend.jobs.queue), 0)
- # Pretend the dependency check was successful
+ # Pretend the install check was successful
for job in build.jobs:
- job._set_attribute("depcheck_succeeded", True)
+ job._set_attribute("installcheck_succeeded", True)
# There should now be two jobs in the queue
self.assertEqual(len(self.backend.jobs.queue), 2)