Skip to content
Snippets Groups Projects
Commit b4aed40c authored by Carsten Patzke's avatar Carsten Patzke
Browse files

Monitoring: Python tests, added 'auto' pipelineId and instanceId

parent 4799b2e1
No related branches found
No related tags found
No related merge requests found
Showing with 12 additions and 12 deletions
...@@ -10,7 +10,7 @@ endpoint = "localhost:8400" ...@@ -10,7 +10,7 @@ endpoint = "localhost:8400"
beamtime = "asapo_test" beamtime = "asapo_test"
# source type 'processed' to write to the core filesystem # source type 'processed' to write to the core filesystem
producer = asapo_producer.create_producer(endpoint,'processed', producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',
beamtime,'auto','test_source','', 1,60000) beamtime,'auto','test_source','', 1,60000)
# we are sending a message with with index 1 to the default stream. Filename must start with processed/ # we are sending a message with with index 1 to the default stream. Filename must start with processed/
......
...@@ -10,7 +10,7 @@ endpoint = "localhost:8400" ...@@ -10,7 +10,7 @@ endpoint = "localhost:8400"
beamtime = "asapo_test" beamtime = "asapo_test"
# source type 'processed' to write to the core filesystem # source type 'processed' to write to the core filesystem
producer = asapo_producer.create_producer(endpoint,'processed', producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',
beamtime,'auto','test_source','', 1,60000) beamtime,'auto','test_source','', 1,60000)
# we are sending a message with with index 1 to the default stream. Filename must start with processed/ # we are sending a message with with index 1 to the default stream. Filename must start with processed/
......
...@@ -25,7 +25,7 @@ class AsapoSender: ...@@ -25,7 +25,7 @@ class AsapoSender:
def _callback(self, header, err): def _callback(self, header, err):
print ("hello self callback") print ("hello self callback")
producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads, 600000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads, 600000)
producer.set_log_level("debug") producer.set_log_level("debug")
print(asapo_producer.__version__) print(asapo_producer.__version__)
......
...@@ -27,7 +27,7 @@ def callback(header,err): ...@@ -27,7 +27,7 @@ def callback(header,err):
lock.release() lock.release()
producer = asapo_producer.create_producer(endpoint,'processed','auto',beamline, data_source, token, nthreads, 60000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed','auto',beamline, data_source, token, nthreads, 60000)
producer.set_log_level("debug") producer.set_log_level("debug")
......
...@@ -47,7 +47,7 @@ def assert_version(version): ...@@ -47,7 +47,7 @@ def assert_version(version):
if not ok: if not ok:
sys.exit(1) sys.exit(1)
producer = asapo_producer.create_producer(endpoint,'processed', beamtime, 'auto', data_source, token, nthreads, 60000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed', beamtime, 'auto', data_source, token, nthreads, 60000)
producer.set_log_level("debug") producer.set_log_level("debug")
...@@ -233,7 +233,7 @@ else: ...@@ -233,7 +233,7 @@ else:
# create with error # create with error
try: try:
producer = asapo_producer.create_producer(endpoint,'processed', beamtime, 'auto', data_source, token, 0, 0) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed', beamtime, 'auto', data_source, token, 0, 0)
except asapo_producer.AsapoWrongInputError as e: except asapo_producer.AsapoWrongInputError as e:
print(e) print(e)
else: else:
......
...@@ -26,7 +26,7 @@ def assert_err(err): ...@@ -26,7 +26,7 @@ def assert_err(err):
print(err) print(err)
sys.exit(1) sys.exit(1)
producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads ,0) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads ,0)
producer.set_log_level("debug") producer.set_log_level("debug")
......
...@@ -27,7 +27,7 @@ def assert_err(err): ...@@ -27,7 +27,7 @@ def assert_err(err):
print(err) print(err)
sys.exit(1) sys.exit(1)
producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads ,0) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads ,0)
producer.set_log_level("info") producer.set_log_level("info")
......
...@@ -27,7 +27,7 @@ def assert_err(err): ...@@ -27,7 +27,7 @@ def assert_err(err):
print(err) print(err)
sys.exit(1) sys.exit(1)
producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads, 600000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads, 600000)
producer.set_log_level("debug") producer.set_log_level("debug")
......
...@@ -22,7 +22,7 @@ def callback(header,err): ...@@ -22,7 +22,7 @@ def callback(header,err):
print ("successfuly sent: ",header) print ("successfuly sent: ",header)
lock.release() lock.release()
producer = asapo_producer.create_producer(endpoint,'processed',beamtime, 'auto', data_source, token, nthreads, 600000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime, 'auto', data_source, token, nthreads, 600000)
producer.set_log_level("info") producer.set_log_level("info")
...@@ -63,7 +63,7 @@ if n!=0: ...@@ -63,7 +63,7 @@ if n!=0:
# create with error # create with error
try: try:
producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, 0, 600000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, 0, 600000)
except Exception as Asapo: except Exception as Asapo:
print(e) print(e)
else: else:
......
...@@ -22,7 +22,7 @@ def callback(header,err): ...@@ -22,7 +22,7 @@ def callback(header,err):
print ("successfuly sent: ",header) print ("successfuly sent: ",header)
lock.release() lock.release()
producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads, 600000) producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads, 600000)
producer.set_log_level("info") producer.set_log_level("info")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment