From 29bafbc1e46cca63e6d38133bda9d02848edcfeb Mon Sep 17 00:00:00 2001 From: Josh Date: Wed, 22 Jul 2026 14:24:24 -0400 Subject: [PATCH] fix(background-jobs): bind Snowflake job IDs as strings Signed-off-by: Josh --- lib/private/BackgroundJob/JobList.php | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/lib/private/BackgroundJob/JobList.php b/lib/private/BackgroundJob/JobList.php index e4c9157306b..2c63ef17771 100644 --- a/lib/private/BackgroundJob/JobList.php +++ b/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(); }