aiogear - pypi Package Compare versions

Comparing version 0.2.4 to 0.2.5

aiogear/__init__.py

@@ -5,4 +5,5 @@ from aiogear.worker import Worker
 from aiogear.packet import Type as PacketType
+from aiogear.callback_client import CallbackClient
 
 
-__all__ = ['Worker', 'Client', 'Admin', 'PacketType']
+__all__ = ['Worker', 'Client', 'Admin', 'PacketType',  'CallbackClient']

aiogear/callback_client.py

@@ -65,3 +65,4 @@ import asyncio
         self.do_register(self.jobs_completed, PACKET_TYPES.WORK_COMPLETE, PACKET_TYPES.WORK_FAIL, PACKET_TYPES.WORK_EXCEPTION)
-        self.do_register(self.job_data, PACKET_TYPES.WORK_DATA, PACKET_TYPES.WORK_WARNING)
+        self.do_register(self.job_data, PACKET_TYPES.WORK_DATA)
+        self.do_register(self.job_warning, PACKET_TYPES.WORK_WARNING)
         self.do_register(self.job_status, PACKET_TYPES.WORK_STATUS)
@@ -153,13 +154,10 @@
     def job_data(self, packet):
-        handle, output = self._split(packet[1])
+        noti_type, data = packet
+        handle, output = data
+        self.notify('data', handle, output)
 
-        if packet[0] == PACKET_TYPES.WORK_WARNING:
-            msg = 'warning'
-        elif packet[0] == PACKET_TYPES.WORK_DATA:
-            msg = 'data'
-        else:
-            msg = 'unknown'
+    def job_warning(self, packet):
+        handle, output = map(lambda i: i.decode('ascii'), self._split(packet[1]))
+        self.notify('warning', handle, output)
 
-        self.notify(msg, handle.decode('ascii'), output.decode('ascii'))
-
     def job_status(self, packet):
@@ -166,0 +164,0 @@ parts = self._split(packet[1])

METADATA

 Metadata-Version: 2.0
 Name: aiogear
-Version: 0.2.4
+Version: 0.2.5
 Summary: Asynchronous gearman protocol based on asyncio
@@ -5,0 +5,0 @@ Home-page: https://github.com/sardok/aiogear

metadata.json

@@ -1,1 +0,1 @@
-{"classifiers": ["Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6"], "extensions": {"python.details": {"contacts": [{"email": "[e-mail]", "name": "Sinan Nalkaya", "role": "author"}], "document_names": {"description": "DESCRIPTION.rst", "license": "LICENSE.txt"}, "project_urls": {"Home": "https://github.com/sardok/aiogear"}}}, "generator": "bdist_wheel (0.30.0.a0)", "metadata_version": "2.0", "name": "aiogear", "summary": "Asynchronous gearman protocol based on asyncio", "version": "0.2.4"}
+{"classifiers": ["Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6"], "extensions": {"python.details": {"contacts": [{"email": "[e-mail]", "name": "Sinan Nalkaya", "role": "author"}], "document_names": {"description": "DESCRIPTION.rst", "license": "LICENSE.txt"}, "project_urls": {"Home": "https://github.com/sardok/aiogear"}}}, "generator": "bdist_wheel (0.29.0)", "metadata_version": "2.0", "name": "aiogear", "summary": "Asynchronous gearman protocol based on asyncio", "version": "0.2.5"}

RECORD

@@ -1,4 +0,4 @@
-aiogear/__init__.py,sha256=Jb6Ri1RG9Apy1k1Tf9EyuiVb_zWyFyHz1mqn0OJ7EYU,209
+aiogear/__init__.py,sha256=TGDf34BAI2sSrypynhsNbbOzF4XNgYOS2fN8AqW4XT0,280
 aiogear/admin.py,sha256=BSdZuJppER_hyupbrsZpW3EY3Nkb_83KX3ZLnmb9Z14,3980
-aiogear/callback_client.py,sha256=vGEbqxbMblbrk_pUTO3fI6ke9-VShzuEgiPtP2Fev8Q,6804
+aiogear/callback_client.py,sha256=AC7QHj0UgNZIrpvL4ppHfcO_MjEi4IGYNicOtCaWPjc,6798
 aiogear/client.py,sha256=9vXceRcI1VmUyUaL_iSG-7ts743_UXP1_OnmfReM7tw,3269
@@ -11,8 +11,8 @@ aiogear/exception.py,sha256=q7t8kbd7JunJUVt11kiTbCsDZazc2GqJv8XhML1kV0w,279
 aiogear/worker.py,sha256=JnUTNDAEv0thbHapmNnIaQxBHgV9ZUeLjY0DyxAhFBE,6103
-aiogear-0.2.4.dist-info/DESCRIPTION.rst,sha256=OCTuuN6LcWulhHS3d5rfjdsQtW22n7HENFRh6jC6ego,10
-aiogear-0.2.4.dist-info/LICENSE.txt,sha256=aKOlcsi-w9drg2PRQfoa4M83mS9FacyriPb3UPVLfWY,1091
-aiogear-0.2.4.dist-info/METADATA,sha256=K1bXdRtxhcHNn8YQ7BAIBUywSCHsG4tBtquC_IKyfzk,351
-aiogear-0.2.4.dist-info/RECORD,,
-aiogear-0.2.4.dist-info/WHEEL,sha256=5wvfB7GvgZAbKBSE9uX9Zbi6LCL-_KgezgHblXhCRnM,113
-aiogear-0.2.4.dist-info/metadata.json,sha256=isXcQTaf3SBzO0AQDA2_n1c1YSZg9wshn3Yt3HOBt3M,533
-aiogear-0.2.4.dist-info/top_level.txt,sha256=qHWIyKhLqElUnOY4Bm8ZxgFoQ6DPzIqZiXzYibRco-8,8
+aiogear-0.2.5.dist-info/DESCRIPTION.rst,sha256=OCTuuN6LcWulhHS3d5rfjdsQtW22n7HENFRh6jC6ego,10
+aiogear-0.2.5.dist-info/LICENSE.txt,sha256=aKOlcsi-w9drg2PRQfoa4M83mS9FacyriPb3UPVLfWY,1091
+aiogear-0.2.5.dist-info/METADATA,sha256=CkGAa4xa7PMmXauItPwPqzOAKVmAmNC8bI4W-CaIGzQ,351
+aiogear-0.2.5.dist-info/RECORD,,
+aiogear-0.2.5.dist-info/WHEEL,sha256=o2k-Qa-RMNIJmUdIc7KU6VWR_ErNRbWNlxDIpl7lm34,110
+aiogear-0.2.5.dist-info/metadata.json,sha256=NykG5AQn-NoCZQwrjr2e3a6tqfNwa-_ZSG8XE9YuqMM,530
+aiogear-0.2.5.dist-info/top_level.txt,sha256=qHWIyKhLqElUnOY4Bm8ZxgFoQ6DPzIqZiXzYibRco-8,8

WHEEL

 Wheel-Version: 1.0
-Generator: bdist_wheel (0.30.0.a0)
+Generator: bdist_wheel (0.29.0)
 Root-Is-Purelib: true
@@ -4,0 +4,0 @@ Tag: py2-none-any

Alert delta unavailable

Currently unable to show alert delta for PyPI packages.

No metric changes