Fix InvalidCastException during job fetch with older schemas

HangfireIO · Dec 3, 2024 · 58ec10d · 58ec10d
1 parent 0e9ea33
commit 58ec10d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Hangfire.SqlServer/SqlServerJobQueue.cs b/src/Hangfire.SqlServer/SqlServerJobQueue.cs
@@ -180,8 +180,8 @@ private SqlServerTimeoutJob FetchJob(string[] queues)
 
                 if (!reader.Read()) return null;
 
-                var id = reader.GetInt64(reader.GetOrdinal("Id"));
-                var jobId = reader.GetInt64(reader.GetOrdinal("JobId"));
+                var id = Convert.ToInt64(reader.GetValue(reader.GetOrdinal("Id")), CultureInfo.InvariantCulture); // Can be Int32 in older schemas
+                var jobId = Convert.ToInt64(reader.GetValue(reader.GetOrdinal("JobId")), CultureInfo.InvariantCulture); // Can be Int32 in older schemas
                 var queue = reader.GetString(reader.GetOrdinal("Queue"));
                 var fetchedAt = reader.GetDateTime(reader.GetOrdinal("FetchedAt"));
 
@@ -243,7 +243,7 @@ private SqlServerTransactionJob DequeueUsingTransaction(string[] queues, Cancell
                     {
                         if (reader.Read())
                         {
-                            var jobId = reader.GetInt64(reader.GetOrdinal("JobId"));
+                            var jobId = Convert.ToInt64(reader.GetValue(reader.GetOrdinal("JobId")), CultureInfo.InvariantCulture); // Can be Int32 in older schemas
                             var queue = reader.GetString(reader.GetOrdinal("Queue"));
 
                             if (reader.Read())