()
| 1428 | wait_for_condition(lambda: file_exists(temp_dir), timeout=30) |
| 1429 | |
| 1430 | def verify(): |
| 1431 | tags = read_file(temp_dir, "usage_stats")["extra_usage_tags"] |
| 1432 | num_nodes = read_file(temp_dir, "usage_stats")["total_num_nodes"] |
| 1433 | assert tags == { |
| 1434 | "key": "val", |
| 1435 | "key2": "val2", |
| 1436 | "dashboard_metrics_grafana_enabled": "False", |
| 1437 | "dashboard_metrics_prometheus_enabled": "False", |
| 1438 | "gcs_storage": gcs_storage_type, |
| 1439 | "dashboard_used": "False", |
| 1440 | "actor_num_created": "0", |
| 1441 | "pg_num_created": "0", |
| 1442 | "num_actor_creation_tasks": "0", |
| 1443 | "num_actor_tasks": "0", |
| 1444 | "num_normal_tasks": "0", |
| 1445 | "num_drivers": "1", |
| 1446 | } |
| 1447 | assert num_nodes == 2 |
| 1448 | return True |
| 1449 | |
| 1450 | wait_for_condition(verify) |
| 1451 |
nothing calls this directly
no test coverage detected
searching dependent graphs…