run jobs

servicetests/tests/JobsExecution/jobs.py

@@ -265,9 +265,6 @@ def on_update_job_execution_rejected(rejected):
         keep_alive_secs=30,
         http_proxy_options=proxy_options)
 
-    if not cmdData.input_is_ci:
-        print(f"Connecting to {cmdData.input_endpoint} with client ID '{cmdData.input_clientId}'...")
-    else:
         print("Connecting to endpoint with client ID")
 
     connected_future = mqtt_connection.connect()
@@ -311,22 +308,6 @@ def on_update_job_execution_rejected(rejected):
     except Exception as e:
         exit(e)
 
-    # Wait until we get a response. If we do not get a response after 50 tries, then abort
-    got_job_response_tries = 0
-    while (locked_data.got_job_response == False):
-        got_job_response_tries += 1
-        if (got_job_response_tries > 50):
-            exit("Got job response timeout exceeded")
-            sys.exit(-1)
-        time.sleep(0.2)
-
-    if (len(available_jobs) > 0):
-        print("At least one job queued in CI! No further work to do. Exiting sample...")
-        sys.exit(0)
-    else:
-        print("ERROR: No jobs queued in CI! At least one job should be queued!")
-        sys.exit(-1)
-
     try:
         # Subscribe to necessary topics.
         # Note that is **is** important to wait for "accepted/rejected" subscriptions