correctly close conn

vapor · Feb 12, 2019 · e943ae8 · e943ae8
1 parent a319c7a
commit e943ae8
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/Sources/JobsRedisDriver/JobsRedisDriver.swift b/Sources/JobsRedisDriver/JobsRedisDriver.swift
@@ -33,7 +33,11 @@ extension JobsRedisDriver: JobsPersistenceLayer {
         return database.newConnection(on: eventLoop).flatMap { conn in
             return conn.rpoplpush(source: key, destination: processing).and(result: conn)
         }.flatMap(to: (RedisData, RedisClient).self) { redisData, conn in
-            guard let id = redisData.string else { throw Abort(.internalServerError) }
+            guard let id = redisData.string else {
+                conn.close()
+                throw Abort(.internalServerError)
+            }
+
             return conn.rawGet(id).and(result: conn)
         }.map { redisData, conn in
             conn.close()