aiogear
Advanced tools
| Metadata-Version: 1.1 | ||
| Name: aiogear | ||
| Version: 0.2.2 | ||
| Version: 0.2.3 | ||
| Summary: Asynchronous gearman protocol based on asyncio | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/sardok/aiogear |
@@ -52,8 +52,9 @@ import asyncio | ||
| uuid = self.uuid() | ||
| jc_f = self.wait_for(Type.JOB_CREATED) | ||
| w_f = self.wait_for(Type.WORK_COMPLETE, Type.WORK_FAIL, Type.WORK_EXCEPTION) | ||
| self.send(packet, name, uuid, *args) | ||
| job_created = await self.wait_for(Type.JOB_CREATED) | ||
| f = self.wait_for(Type.WORK_COMPLETE, Type.WORK_FAIL, Type.WORK_EXCEPTION) | ||
| job_created = await jc_f | ||
| handle = job_created.handle | ||
| self.handles[handle] = f | ||
| f.add_done_callback(lambda _: self.handles.pop(handle)) | ||
| self.handles[handle] = w_f | ||
| w_f.add_done_callback(lambda _: self.handles.pop(handle)) | ||
| return job_created | ||
@@ -60,0 +61,0 @@ |
+1
-1
| Metadata-Version: 1.1 | ||
| Name: aiogear | ||
| Version: 0.2.2 | ||
| Version: 0.2.3 | ||
| Summary: Asynchronous gearman protocol based on asyncio | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/sardok/aiogear |
+1
-1
@@ -5,3 +5,3 @@ from setuptools import setup | ||
| name='aiogear', | ||
| version='0.2.2', | ||
| version='0.2.3', | ||
| author='Sinan Nalkaya', | ||
@@ -8,0 +8,0 @@ author_email='sardok@gmail.com', |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
22472
0.12%540
0.19%