Commit 1a57979a authored by Manuela Kuhn's avatar Manuela Kuhn

Added missing files to freeze

parent 9a538890
......@@ -14,6 +14,7 @@ import platform
basepath = os.path.dirname(os.path.abspath(__file__))
senderpath = os.path.join(basepath, "src", "sender")
sharedpath = os.path.join(basepath, "src", "shared")
apipath = os.path.join(basepath, "src", "APIs", "hidra")
confpath = os.path.join(basepath, "conf")
libzmq_path = os.path.join(get_python_lib(), "zmq")
platform_specific_files = []
......@@ -105,7 +106,9 @@ build_exe_options = {
(os.path.join(senderpath, "datafetchers", "zmq_fetcher.py"),
os.path.join("datafetchers", "zmq_fetcher.py")),
(os.path.join(senderpath, "datafetchers", "cleanerbase.py"),
os.path.join("datafetchers", "cleanerbase.py"))
os.path.join("datafetchers", "cleanerbase.py")),
# apis
(apipath, "hidra"),
] + platform_specific_files,
}
......
......@@ -247,8 +247,8 @@ def argument_parsing():
"data_fetcher_type",
"store_data",
"use_data_stream",
"chunksize",
"local_target"]
"chunksize"]
# "local_target"]
# Check format of config
check_passed, config_reduced = helpers.check_config(required_params,
......@@ -474,14 +474,17 @@ class DataManager():
self.fixed_stream_id = ("{0}:{1}"
.format(self.params["data_stream_targets"][0][0],
self.params["data_stream_targets"][0][1]))
self.status_check_id = ("{0}:{1}"
.format(self.params["data_stream_targets"][0][0],
self.params["status_check_port"]))
if self.params["remove_data"] == "deferred_error_handling":
self.status_check_id = ("{0}:{1}"
.format(self.params["data_stream_targets"][0][0],
self.params["status_check_port"]))
self.log.info("Enabled receiver checking")
self.check_target_host = self.check_status_receiver
else:
self.status_check_id = None
self.log.info("Enabled alive test")
self.check_target_host = self.test_fixed_streaming_host
......
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