|
|
@ -1,6 +1,8 @@ |
|
|
|
#!/usr/bin/env python3 |
|
|
|
#!/usr/bin/env python3 |
|
|
|
|
|
|
|
from functools import lru_cache |
|
|
|
import sys |
|
|
|
import sys |
|
|
|
import subprocess |
|
|
|
import subprocess |
|
|
|
|
|
|
|
from tqdm import tqdm |
|
|
|
from azure.storage.blob import BlockBlobService # pylint: disable=import-error |
|
|
|
from azure.storage.blob import BlockBlobService # pylint: disable=import-error |
|
|
|
|
|
|
|
|
|
|
|
from selfdrive.car.tests.routes import routes as test_car_models_routes |
|
|
|
from selfdrive.car.tests.routes import routes as test_car_models_routes |
|
|
@ -15,6 +17,7 @@ SOURCES = [ |
|
|
|
] |
|
|
|
] |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@lru_cache |
|
|
|
def get_azure_keys(): |
|
|
|
def get_azure_keys(): |
|
|
|
dest_key = azureutil.get_user_token(_DATA_ACCOUNT_CI, "openpilotci") |
|
|
|
dest_key = azureutil.get_user_token(_DATA_ACCOUNT_CI, "openpilotci") |
|
|
|
source_keys = [azureutil.get_user_token(account, bucket) for account, bucket in SOURCES] |
|
|
|
source_keys = [azureutil.get_user_token(account, bucket) for account, bucket in SOURCES] |
|
|
@ -82,7 +85,7 @@ if __name__ == "__main__": |
|
|
|
to_sync.extend([rt.route for rt in test_car_models_routes]) |
|
|
|
to_sync.extend([rt.route for rt in test_car_models_routes]) |
|
|
|
to_sync.extend([s[1].rsplit('--', 1)[0] for s in replay_segments]) |
|
|
|
to_sync.extend([s[1].rsplit('--', 1)[0] for s in replay_segments]) |
|
|
|
|
|
|
|
|
|
|
|
for r in to_sync: |
|
|
|
for r in tqdm(to_sync): |
|
|
|
if not sync_to_ci_public(r): |
|
|
|
if not sync_to_ci_public(r): |
|
|
|
failed_routes.append(r) |
|
|
|
failed_routes.append(r) |
|
|
|
|
|
|
|
|
|
|
|