diff --git a/execution/strategies/tests/test_domain_restriction_binary_search_strategy.py b/execution/strategies/tests/test_domain_restriction_binary_search_strategy.py index ed727ad607c99def55f429e97a0e66cf0eb72397..d93d4924cf09015c714604f2fc995e1db971e69d 100644 --- a/execution/strategies/tests/test_domain_restriction_binary_search_strategy.py +++ b/execution/strategies/tests/test_domain_restriction_binary_search_strategy.py @@ -88,6 +88,7 @@ def test_binary_search_strategy(): # execute experiment_config = ExperimentConfig( + exp_id="0", use_case=uc, dim_values=dim_values, replicass=replicass, diff --git a/execution/strategies/tests/test_domain_restriction_check_all_strategy.py b/execution/strategies/tests/test_domain_restriction_check_all_strategy.py index 33c32944b82d095e1b247a7bb7e84fe702c3f147..c15daca6ebab3171f0995c048afe56c0185efe56 100644 --- a/execution/strategies/tests/test_domain_restriction_check_all_strategy.py +++ b/execution/strategies/tests/test_domain_restriction_check_all_strategy.py @@ -103,6 +103,7 @@ def test_linear_search_strategy(): # execute experiment_config = ExperimentConfig( + exp_id="0", use_case=uc, dim_values=dim_values, replicass=replicass, diff --git a/execution/strategies/tests/test_domain_restriction_linear_search_strategy.py b/execution/strategies/tests/test_domain_restriction_linear_search_strategy.py index 9188b471949b2d0a505337a0b401df3f30da2763..86e2cd29d187cb83166102c503ee79e5e1424573 100644 --- a/execution/strategies/tests/test_domain_restriction_linear_search_strategy.py +++ b/execution/strategies/tests/test_domain_restriction_linear_search_strategy.py @@ -84,6 +84,7 @@ def test_linear_search_strategy(): # execute experiment_config = ExperimentConfig( + exp_id="0", use_case=uc, dim_values=dim_values, replicass=replicass, diff --git a/execution/strategies/tests/test_no_restriction_binary_search_strategy.py b/execution/strategies/tests/test_no_restriction_binary_search_strategy.py index 52ad2e0e7fc88038a2aa276ac967ccdd482d2e85..4f5da89cc72edd792015763539c9af4677772a79 100644 --- a/execution/strategies/tests/test_no_restriction_binary_search_strategy.py +++ b/execution/strategies/tests/test_no_restriction_binary_search_strategy.py @@ -93,6 +93,7 @@ def test_binary_search_strategy(): # execute experiment_config = ExperimentConfig( + exp_id="0", use_case=uc, dim_values=dim_values, replicass=replicass, diff --git a/execution/strategies/tests/test_no_restriction_check_all_strategy.py b/execution/strategies/tests/test_no_restriction_check_all_strategy.py index 6f0a0eed500bd925166846ccdbfcda0a7d1c1095..f173a3d168704cc7a499933984b6510ebda2751e 100644 --- a/execution/strategies/tests/test_no_restriction_check_all_strategy.py +++ b/execution/strategies/tests/test_no_restriction_check_all_strategy.py @@ -120,6 +120,7 @@ def test_linear_search_strategy(): # execute experiment_config = ExperimentConfig( + exp_id="0", use_case=uc, dim_values=dim_values, replicass=replicass, diff --git a/execution/strategies/tests/test_no_restriction_linear_search_strategy.py b/execution/strategies/tests/test_no_restriction_linear_search_strategy.py index a7fd68b9b5b0c99ea6cd443c889d925d357b22cf..0e47c2e95b75ae682e82a02ad3d0a91c5a62f253 100644 --- a/execution/strategies/tests/test_no_restriction_linear_search_strategy.py +++ b/execution/strategies/tests/test_no_restriction_linear_search_strategy.py @@ -101,6 +101,7 @@ def test_linear_search_strategy(): # execute experiment_config = ExperimentConfig( + exp_id="0", use_case=uc, dim_values=dim_values, replicass=replicass, diff --git a/execution/theodolite.py b/execution/theodolite.py index 6049f3ffac61af46212f521a91870e57342be478..741d7e2ea74d6694c003b114dbc5f703c3d056d6 100755 --- a/execution/theodolite.py +++ b/execution/theodolite.py @@ -21,7 +21,7 @@ memory_limit=sys.argv[6] if len(sys.argv) >= 7 and sys.argv[6] else "4Gi" kafka_streams_commit_interval_ms=sys.argv[7] if len(sys.argv) >= 8 and sys.argv[7] else 100 execution_minutes=sys.argv[8] if len(sys.argv) >= 9 and sys.argv[8] else 5 domain_restriction=bool(sys.argv[9]) if len(sys.argv) >= 10 and sys.argv[9] == "restrict-domain" else False -search_strategy=sys.argv[10] if len(sys.argv) >= 11 and (sys.argv[10] == "linear-search" or sys.argv[10] == "binary-search") else "default" +search_strategy=sys.argv[10] if len(sys.argv) >= 11 and (sys.argv[10] == "linear-search" or sys.argv[10] == "binary-search") else "check-all" print(f"Domain restriction of search space activated: {domain_restriction}") print(f"Chosen search strategy: {search_strategy}") @@ -35,6 +35,23 @@ else: with open("exp_counter.txt", mode="w") as write_stream: write_stream.write(str(exp_id+1)) +# Store metadata +separator = "," +lines = [ + f"UC={uc}\n", + f"DIM_VALUES={separator.join(dim_values)}\n", + f"REPLICAS={separator.join(replicas)}\n", + f"PARTITIONS={partitions}\n", + f"CPU_LIMIT={cpu_limit}\n", + f"MEMORY_LIMIT={memory_limit}\n", + f"KAFKA_STREAMS_COMMIT_INTERVAL_MS={kafka_streams_commit_interval_ms}\n", + f"EXECUTION_MINUTES={execution_minutes}\n", + f"DOMAIN_RESTRICTION={domain_restriction}\n", + f"SEARCH_STRATEGY={search_strategy}" + ] +with open(f"exp{exp_id}_uc{uc}_meta.txt", "w") as stream: + stream.writelines(lines) + # domain restriction if domain_restriction: # domain restriction + linear-search