@@ -59,9 +59,10 @@ def execute_test_suite(
59
59
"""Execute a suite of causal tests and return the results in a list"""
60
60
if self .scenario_execution_data_df .empty :
61
61
raise Exception ("No data has been loaded. Please call load_data prior to executing a causal test case." )
62
- causal_test_results = []
62
+ test_suite_results = {}
63
63
for edge in test_suite :
64
-
64
+ print ("edge: " )
65
+ print (edge )
65
66
logger .info ("treatment: %s" , edge .treatment_variable )
66
67
logger .info ("outcome: %s" , edge .outcome_variable )
67
68
minimal_adjustment_set = self .causal_dag .identification (edge )
@@ -78,10 +79,13 @@ def execute_test_suite(
78
79
estimators = test_suite [edge ]["estimators" ]
79
80
tests = test_suite [edge ]["tests" ]
80
81
estimate_type = test_suite [edge ]["estimate_type" ]
81
-
82
+ results = []
82
83
for EstimatorClass in estimators :
83
-
84
+ print ("tests: " )
85
+ print (tests )
86
+ causal_test_results = []
84
87
for test in tests :
88
+
85
89
treatment_variable = list (test .treatment_input_configuration .keys ())[0 ]
86
90
treatment_value = list (test .treatment_input_configuration .values ())[0 ]
87
91
control_value = list (test .control_input_configuration .values ())[0 ]
@@ -91,7 +95,10 @@ def execute_test_suite(
91
95
estimator .df = self .scenario_execution_data_df
92
96
causal_test_result = self ._return_causal_test_results (estimate_type , estimator , test )
93
97
causal_test_results .append (causal_test_result )
94
- return causal_test_results
98
+ results .append (causal_test_results )
99
+ test_suite_results [edge ] = results
100
+ breakpoint ()
101
+ return test_suite_results
95
102
96
103
def execute_test (
97
104
self , estimator : type (Estimator ), causal_test_case : CausalTestCase , estimate_type : str = "ate"
0 commit comments