feat(python): makes RedisConnection's close method async, use aclose when possible

python/bullmq/flow_producer.py

@@ -134,8 +134,8 @@ async def addBulk(self, flows: list[dict]):
 
         return result
 
-    def close(self):
+    async def close(self):
         """
         Close the flow instance.
         """
-        return self.redisConnection.close()
+        await self.redisConnection.close()

python/bullmq/queue.py

@@ -308,11 +308,11 @@ def sanitizeJobTypes(self, types):
             'waiting-children'
         ]
 
-    def close(self):
+    async def close(self):
         """
         Close the queue instance.
         """
-        return self.redisConnection.close()
+        await self.redisConnection.close()
 
     def remove(self, job_id: str, opts: dict = {}):
         return self.scripts.remove(job_id, opts.get("removeChildren", True))

python/bullmq/redis_connection.py

@@ -50,11 +50,14 @@ def disconnect(self):
         """
         return self.conn.disconnect()
 
-    def close(self):
+    async def close(self):
         """
         Close the connection
         """
-        return self.conn.close()
+        try:
+            await self.conn.aclose()
+        except AttributeError:
+            await self.conn.close()
 
     async def getRedisVersion(self):
         if self.version is not None: