diff --git a/integration_worker.py b/integration_worker.py
index add52ca0970e91818c76ea48beeaa382360cc73b..9d1e33e0632bab59b80ff4717e34d7f79ce25d73 100755
--- a/integration_worker.py
+++ b/integration_worker.py
@@ -96,6 +96,9 @@ PROCESSING_MODULES = {
 
 
 def log_setup(long):
+    # pika log level
+    logging.getLogger("pika").setLevel(logging.WARNING)
+
     # log to file
     logfile = os.path.join(LOG_DIR, "integrationworker")
     if long: