@@ -66,6 +66,7 @@ class TestExperiments(e2e_base.TestEndToEnd):
66
66
67
67
def setup_class (cls ):
68
68
cls ._experiment_name = cls ._make_display_name ("" )[:64 ]
69
+ cls ._experiment_name_2 = cls ._make_display_name ("" )[:64 ]
69
70
cls ._experiment_model_name = cls ._make_display_name ("sklearn-model" )[:64 ]
70
71
cls ._dataset_artifact_name = cls ._make_display_name ("" )[:64 ]
71
72
cls ._dataset_artifact_uri = cls ._make_display_name ("ds-uri" )
@@ -165,18 +166,29 @@ def test_log_time_series_metrics(self):
165
166
_TIME_SERIES_METRIC_KEY : [float (value ) for value in range (5 )],
166
167
}
167
168
168
- def test_get_time_series_data_frame_batch_read_success (self ):
169
+ def test_get_time_series_data_frame_batch_read_success (self , shared_state ):
170
+ tensorboard = aiplatform .Tensorboard .create (
171
+ project = e2e_base ._PROJECT ,
172
+ location = e2e_base ._LOCATION ,
173
+ display_name = self ._experiment_name_2 ,
174
+ )
175
+ shared_state ["resources" ] = [tensorboard ]
169
176
aiplatform .init (
170
177
project = e2e_base ._PROJECT ,
171
178
location = e2e_base ._LOCATION ,
172
- experiment = self ._experiment_name ,
179
+ experiment = self ._experiment_name_2 ,
180
+ experiment_tensorboard = tensorboard ,
173
181
)
174
- aiplatform .start_run (_RUN , resume = True )
182
+ shared_state ["resources" ].append (
183
+ aiplatform .metadata .metadata ._experiment_tracker .experiment
184
+ )
185
+ aiplatform .start_run (_RUN )
175
186
for i in range (_READ_TIME_SERIES_BATCH_SIZE + 1 ):
176
187
aiplatform .log_time_series_metrics ({f"{ _TIME_SERIES_METRIC_KEY } -{ i } " : 1 })
177
188
178
- run = aiplatform .ExperimentRun (run_name = _RUN , experiment = self ._experiment_name )
179
-
189
+ run = aiplatform .ExperimentRun (
190
+ run_name = _RUN , experiment = self ._experiment_name_2
191
+ )
180
192
time_series_result = run .get_time_series_data_frame ()
181
193
182
194
assert len (time_series_result ) > _READ_TIME_SERIES_BATCH_SIZE
@@ -427,8 +439,6 @@ def test_get_experiments_df(self):
427
439
true_df_dict_1 ["state" ] = aiplatform .gapic .Execution .State .COMPLETE .name
428
440
true_df_dict_1 ["run_type" ] = aiplatform .metadata .constants .SYSTEM_EXPERIMENT_RUN
429
441
true_df_dict_1 [f"time_series_metric.{ _TIME_SERIES_METRIC_KEY } " ] = 4.0
430
- for i in range (_READ_TIME_SERIES_BATCH_SIZE + 1 ):
431
- true_df_dict_1 [f"time_series_metric.{ _TIME_SERIES_METRIC_KEY } -{ i } " ] = 1.0
432
442
433
443
true_df_dict_2 = {f"metric.{ key } " : value for key , value in _METRICS_2 .items ()}
434
444
for key , value in _PARAMS_2 .items ():
@@ -439,6 +449,7 @@ def test_get_experiments_df(self):
439
449
true_df_dict_2 ["state" ] = aiplatform .gapic .Execution .State .COMPLETE .name
440
450
true_df_dict_2 ["run_type" ] = aiplatform .metadata .constants .SYSTEM_EXPERIMENT_RUN
441
451
true_df_dict_2 [f"time_series_metric.{ _TIME_SERIES_METRIC_KEY } " ] = 0.0
452
+ true_df_dict_2 .update (pipelines_param_and_metrics )
442
453
443
454
true_df_dict_3 = {
444
455
"experiment_name" : self ._experiment_name ,
0 commit comments