fix(background-jobs): bind Snowflake job IDs as strings

Signed-off-by: Josh <josh.t.richards@gmail.com>
pull/62425/head
Josh 4 weeks ago committed by GitHub
parent dab318ff69
commit 29bafbc1e4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
  1. 10
      lib/private/BackgroundJob/JobList.php

@ -116,7 +116,7 @@ class JobList implements IJobList {
public function removeById(string $id): void {
$query = $this->connection->getQueryBuilder();
$query->delete('jobs')
->where($query->expr()->eq('id', $query->createNamedParameter($id, IQueryBuilder::PARAM_INT)));
->where($query->expr()->eq('id', $query->createNamedParameter($id)));
$query->executeStatement();
}
@ -266,7 +266,7 @@ class JobList implements IJobList {
$reset->update('jobs')
->set('reserved_at', $reset->expr()->literal(0, IQueryBuilder::PARAM_INT))
->set('last_checked', $reset->createNamedParameter($this->timeFactory->getTime() + 12 * 3600, IQueryBuilder::PARAM_INT))
->where($reset->expr()->eq('id', $reset->createNamedParameter($row['id'], IQueryBuilder::PARAM_INT)));
->where($reset->expr()->eq('id', $reset->createNamedParameter($row['id'])));
$reset->executeStatement();
// Background job from disabled app, try again.
@ -359,7 +359,7 @@ class JobList implements IJobList {
$query = $this->connection->getQueryBuilder();
$query->update('jobs')
->set('reserved_at', $query->expr()->literal(0, IQueryBuilder::PARAM_INT))
->where($query->expr()->eq('id', $query->createNamedParameter($job->getId(), IQueryBuilder::PARAM_INT)));
->where($query->expr()->eq('id', $query->createNamedParameter($job->getId())));
$query->executeStatement();
}
@ -384,7 +384,7 @@ class JobList implements IJobList {
$query->update('jobs')
->set('execution_duration', $query->createNamedParameter($timeTaken, IQueryBuilder::PARAM_INT))
->set('reserved_at', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT))
->where($query->expr()->eq('id', $query->createNamedParameter($job->getId(), IQueryBuilder::PARAM_INT)));
->where($query->expr()->eq('id', $query->createNamedParameter($job->getId())));
$query->executeStatement();
}
@ -394,7 +394,7 @@ class JobList implements IJobList {
$query->update('jobs')
->set('last_run', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT))
->set('reserved_at', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT))
->where($query->expr()->eq('id', $query->createNamedParameter($job->getId()), IQueryBuilder::PARAM_INT));
->where($query->expr()->eq('id', $query->createNamedParameter($job->getId())));
$query->executeStatement();
}

Loading…
Cancel
Save