diff --git a/pyconductor/ConductorWorker.py b/pyconductor/ConductorWorker.py
index 1c5d8425..6918f115 100644
--- a/pyconductor/ConductorWorker.py
+++ b/pyconductor/ConductorWorker.py
@@ -84,8 +84,7 @@ def poll_and_execute(self, taskType, exec_function, domain=None):
             time.sleep(float(self.polling_interval))
             polled = self.taskClient.pollForTask(taskType, self.worker_id, domain)
             if polled is not None:
-                if self.taskClient.ackTask(polled['taskId'], self.worker_id):
-                    self.execute(polled, exec_function)
+                self.execute(polled, exec_function)
 
     def start(self, taskType, exec_function, wait, domain=None):
         """
diff --git a/pyconductor/conductor.py b/pyconductor/conductor.py
index 04cea5c0..0f7c70a7 100644
--- a/pyconductor/conductor.py
+++ b/pyconductor/conductor.py
@@ -213,14 +213,6 @@ def pollForBatch(self, taskType, count, timeout, workerid, domain=None):
             print('Error while polling ' + str(err))
             return None
 
-    def ackTask(self, taskId, workerid):
-        url = self.makeUrl('{}/ack', taskId)
-        params = {}
-        params['workerid'] = workerid
-        headers = {'Accept': 'application/json'}
-        value = self.post(url, params, None, headers)
-        return value in ['true', True]
-
     def getTasksInQueue(self, taskName):
         url = self.makeUrl('queue/{}', taskName)
         return self.get(url)