Commit c484d8a9 authored by Marius Kriegerowski's avatar Marius Kriegerowski
Browse files

Added timeout argument

parent 74425f5d
Pipeline #22529 passed with stage
in 1 minute and 4 seconds
...@@ -104,6 +104,12 @@ def main(args: list = None, message_bus: MessageBus = None): ...@@ -104,6 +104,12 @@ def main(args: list = None, message_bus: MessageBus = None):
type=str, type=str,
help="Set message bus password.", help="Set message bus password.",
) )
group.add_argument(
"--timeout",
type=int,
default=None,
help="Connection timeout (optional)",
)
parser.add_argument( parser.add_argument(
"-v", "--verbose", action="store_true", help="verbose mode", dest="verbose" "-v", "--verbose", action="store_true", help="verbose mode", dest="verbose"
) )
...@@ -118,7 +124,10 @@ def main(args: list = None, message_bus: MessageBus = None): ...@@ -118,7 +124,10 @@ def main(args: list = None, message_bus: MessageBus = None):
message_bus = MessageBus() message_bus = MessageBus()
loop.create_task( loop.create_task(
message_bus.connect( message_bus.connect(
host=args.hostname, username=args.username, password=args.password host=args.hostname,
username=args.username,
password=args.password,
timeout=args.timeout,
) )
) )
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment