diff --git a/celery/tasks.py b/celery/tasks.py
new file mode 100644
index 0000000..6e58134
--- /dev/null
+++ b/celery/tasks.py
@@ -0,0 +1,10 @@
+from vmcelery import celery
+
+@celery.task
+def add(x, y):
+   return x+y
+
+@celery.task
+def mul(x, y):
+    retrun x*y
+
diff --git a/celery/vmcelery.py b/celery/vmcelery.py
new file mode 100644
index 0000000..8b46e74
--- /dev/null
+++ b/celery/vmcelery.py
@@ -0,0 +1,3 @@
+from celery import Celery
+
+celery = Celery('tasks', backend='amqp', broker='amqp://cloud:test@10.9.1.31/vmdriver')