diff --git a/setup.py b/setup.py
index 347fefec..2ef58a0a 100644
--- a/setup.py
+++ b/setup.py
@@ -78,7 +78,6 @@
         "greenlet==0.4.10",
         "requests==2.2.1",
         "pycontracts==1.7.6",
-        "celery==3.1.25",
         "gevent==1.1.2",
         "redis==2.9.1",
         "six==1.9.0"
diff --git a/snowplow_tracker/emitters.py b/snowplow_tracker/emitters.py
index 2eccb0fb..5c06cb02 100644
--- a/snowplow_tracker/emitters.py
+++ b/snowplow_tracker/emitters.py
@@ -30,8 +30,6 @@
     # Python 3
     from queue import Queue
 
-from celery import Celery
-from celery.contrib.methods import task
 import redis
 import requests
 from contracts import contract, new_contract
@@ -52,15 +50,6 @@
 
 new_contract("redis", lambda x: isinstance(x, (redis.Redis, redis.StrictRedis)))
 
-try:
-    # Check whether a custom Celery configuration module named "snowplow_celery_config" exists
-    import snowplow_celery_config
-    app = Celery()
-    app.config_from_object(snowplow_celery_config)
-
-except ImportError:
-    # Otherwise configure Celery with default settings
-    app = Celery("Snowplow", broker="redis://guest@localhost//")
 
 
 class Emitter(object):
@@ -172,7 +161,6 @@ def reached_limit(self):
         else:
             return self.bytes_queued >= self.byte_limit or len(self.buffer) >= self.buffer_size
 
-    @task(name="Flush")
     def flush(self):
         """
             Sends all events in the buffer to the collector.