Remove 'transport' kwarg fom 'salt.utils.event.get_event'

salt/engines/fluent.py

@@ -78,7 +78,6 @@ def start(host="localhost", port=24224, app="engine"):
     else:
         event_bus = salt.utils.event.get_event(
             "minion",
-            transport=__opts__["transport"],
             opts=__opts__,
             sock_dir=__opts__["sock_dir"],
             listen=True,

salt/engines/http_logstash.py

@@ -80,7 +80,6 @@ def start(url, funs=None, tags=None):
     with salt.utils.event.get_event(
         instance,
         sock_dir=__opts__["sock_dir"],
-        transport=__opts__["transport"],
         opts=__opts__,
     ) as event_bus:
         while True:

salt/engines/logentries.py

@@ -178,7 +178,6 @@ def event_bus_context(opts):
     else:
         event_bus = salt.utils.event.get_event(
             "minion",
-            transport=opts["transport"],
             opts=opts,
             sock_dir=opts["sock_dir"],
             listen=True,

salt/engines/logstash_engine.py

@@ -49,7 +49,6 @@ def event_bus_context(opts):
     else:
         event_bus = salt.utils.event.get_event(
             "minion",
-            transport=opts["transport"],
             opts=opts,
             sock_dir=opts["sock_dir"],
             listen=True,

salt/runners/queue.py

@@ -204,7 +204,6 @@ def process_queue(queue, quantity=1, backend="sqlite", is_runner=False):
     with get_event(
         "master",
         __opts__["sock_dir"],
-        __opts__["transport"],
         opts=__opts__,
         listen=False,
     ) as event_bus:

salt/runners/reactor.py

@@ -58,7 +58,6 @@ def list_(saltenv="base", test=None):
     with salt.utils.event.get_event(
         "master",
         __opts__["sock_dir"],
-        __opts__["transport"],
         opts=__opts__,
         listen=True,
     ) as sevent:
@@ -91,7 +90,6 @@ def add(event, reactors, saltenv="base", test=None):
     with salt.utils.event.get_event(
         "master",
         __opts__["sock_dir"],
-        __opts__["transport"],
         opts=__opts__,
         listen=True,
     ) as sevent:
@@ -123,7 +121,6 @@ def delete(event, saltenv="base", test=None):
     with salt.utils.event.get_event(
         "master",
         __opts__["sock_dir"],
-        __opts__["transport"],
         opts=__opts__,
         listen=True,
     ) as sevent:
@@ -154,7 +151,6 @@ def is_leader():
     with salt.utils.event.get_event(
         "master",
         __opts__["sock_dir"],
-        __opts__["transport"],
         opts=__opts__,
         listen=True,
     ) as sevent:
@@ -183,7 +179,6 @@ def set_leader(value=True):
     with salt.utils.event.get_event(
         "master",
         __opts__["sock_dir"],
-        __opts__["transport"],
         opts=__opts__,
         listen=True,
     ) as sevent:

tests/eventlisten.py

@@ -110,7 +110,6 @@ def listen(opts):
     event = salt.utils.event.get_event(
         opts["node"],
         sock_dir=opts["sock_dir"],
-        transport=opts["transport"],
         opts=opts,
         listen=True,
     )