From 90f0a3a8ac5ccc643e7c56011403052cb86870d2 Mon Sep 17 00:00:00 2001
From: Etan Imanol Castro Aldrete <A01209675@itesm.mx>
Date: Sun, 26 Jun 2022 17:32:47 -0500
Subject: [PATCH] Now broker argument can be used

---
 celery_cloudwatch/__main__.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/celery_cloudwatch/__main__.py b/celery_cloudwatch/__main__.py
index 56d9805..edf5713 100644
--- a/celery_cloudwatch/__main__.py
+++ b/celery_cloudwatch/__main__.py
@@ -77,7 +77,7 @@ def main():
     config = config_schema(config_schema(config))
     config_ccwatch = config['ccwatch']
     options = {
-        'broker': config_ccwatch.get('broker'),
+        'broker': args.broker if args.broker else config_ccwatch.get('broker') ,
         'camera': config_ccwatch.get('camera'),
         'verbose': config_ccwatch.get('verbose'),
         'config': config