Do not show sending message in cluster
@@ -55,6 +55,7 @@ class QueueWorker(BaseWorker):
# Queue still has message, try another time
size = self._queue.qsize()
+ if not settings.IN_CLUSTER:
print('Polyaxon worker is attempting to send %i pending messages' % size)
print('Waiting up to {} seconds'.format(self._timeout))
if os.name == 'nt':
