PyPi Release.

LICENSE.txt

@@ -0,0 +1,20 @@
+This is the MIT license: http://www.opensource.org/licenses/mit-license.php
+
+Copyright (c) 2005-2017 the SQLAlchemy authors and contributors <see AUTHORS file>.
+SQLAlchemy is a trademark of Michael Bayer.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of this
+software and associated documentation files (the "Software"), to deal in the Software
+without restriction, including without limitation the rights to use, copy, modify, merge,
+publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons
+to whom the Software is furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all copies or
+substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
+INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
+PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE
+FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+DEALINGS IN THE SOFTWARE.

README.md

@@ -130,13 +130,13 @@ def plus_callback(result):
  * exec_task_on_alice.py 
 ```python
 # -*- encoding: utf-8 -*-
-from crossover import Client, build_callback
+from crossover import Client
 from bob import plus_callback
 
 alice_broker = "redis://localhost:6379/0"
 alice_client = Client(broker=alice_broker)
 
-alice_client.plus(x=340, y=210, callback=build_callback(plus_callback))
+alice_client.plus(x=340, y=210, callback=plus_callback)
 
 ```
 

crossover/__init__.py

@@ -1,6 +1,5 @@
 # -*- encoding: utf-8 -*-
 import celery
-import posixpath
 from celery.utils.log import get_task_logger
 from kombu import Exchange, Queue
 
@@ -34,7 +33,7 @@ def register_router(celery_app):
         celery_app.conf.task_queues = [queue]
 
 
-def build_callback(task):
+def _build_callback(task):
     return {
         'broker': task.app.conf.broker_url,
         'task': task.name
@@ -61,11 +60,13 @@ def __call__(self, *args, **kwargs):
 
 class _Requester(object):
     def __init__(self, broker, remote_task_name, task=CROSSOVER_ROUTER_NAME, queue=CROSSOVER_QUEUE):
-        self.url = "{0}/{1}".format(broker, posixpath.join(task, queue))
+        self.url = "{0}/{1}#{2}".format(broker, task, queue)
         self.remote_task_name = remote_task_name
 
     def __call__(self, *args, **kwargs):
         kwargs['task_name'] = self.remote_task_name
+        if 'callback' in kwargs:
+            kwargs['callback'] = _build_callback(kwargs['callback'])
         requests.post(self.url, json=kwargs)
 
 

examples/project_2/call_p1_add.py

@@ -1,8 +1,8 @@
 # -*- encoding: utf-8 -*-
-from crossover import Client, build_callback
+from crossover import Client
 from examples.project_2.project import plus_callback
 
 p1_broker = "redis://localhost:6379/0"
 project_1_client = Client(broker=p1_broker)
 
-project_1_client.plus(x=340, y=210, callback=build_callback(plus_callback))
+project_1_client.plus(x=340, y=210, callback=plus_callback)

requirements.txt

@@ -1,2 +1,2 @@
 celery[redis]==4.1.0
--e git+https://github.com/debonzi/requests-celery-adapter@783b6e17deb1fc61c0ac85fdb34c56b040ed9c71#egg=rca
+requests-celery-adapters==2.0.1

setup.cfg

@@ -0,0 +1,2 @@
+[metadata]
+description-file = README.md

setup.py

@@ -3,11 +3,26 @@
 
 from setuptools import setup
 
-setup(name='Celery Crossover',
-      version='1.0',
-      description='Celery Crossover',
+requires = [
+    'celery[redis]==4.1.0',
+    'requests-celery-adapters==2.0.4',
+    'six>=1.11.0'
+            ]
+
+extras_require = {
+    'test': [
+        'pytest>=3.2.2'
+    ],
+}
+
+
+setup(name='celery-crossover',
+      version='1.0.0',
+      description='Celery Crossover aims to make it really easy to execute tasks in another service.',
       author='Daniel Debonzi',
       author_email='[email protected]',
+      install_requires=requires,
+      extras_require=extras_require,
       url='https://github.com/debonzi/celery_crossover',
       packages=['crossover', 'examples'],
       )