Skip to content

Commit 50ef23a

Browse files
committed
1 parent 804dd90 commit 50ef23a

5 files changed

Lines changed: 9 additions & 7 deletions

File tree

src/ndi/cloud/download.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -567,7 +567,9 @@ def downloadGenericFiles(
567567
all_docs = []
568568
for doc_id in ndi_document_ids:
569569
q = Query("base.id", "exact_string", doc_id, "")
570-
results = ndi_dataset.database_search(q) if hasattr(ndi_dataset, "database_search") else []
570+
results = (
571+
ndi_dataset.database_search(q) if hasattr(ndi_dataset, "database_search") else []
572+
)
571573
all_docs.extend(results)
572574

573575
if not all_docs:

src/ndi/cloud/internal.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,9 @@ def duplicateDocuments(
288288
for i in range(0, len(doc_ids_to_delete), maximum_delete_batch_size):
289289
batch = doc_ids_to_delete[i : i + maximum_delete_batch_size]
290290
batch_num = i // maximum_delete_batch_size + 1
291-
total_batches = (len(doc_ids_to_delete) + maximum_delete_batch_size - 1) // maximum_delete_batch_size
291+
total_batches = (
292+
len(doc_ids_to_delete) + maximum_delete_batch_size - 1
293+
) // maximum_delete_batch_size
292294
if verbose:
293295
print(f"Deleting batch {batch_num} of {total_batches}...")
294296
try:

src/ndi/cloud/orchestration.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -377,7 +377,6 @@ def newDataset(
377377
# Re-export from upload module (MATLAB: ndi.cloud.upload.scanForUpload)
378378
from .upload import scanForUpload # noqa: F401
379379

380-
381380
# ---------------------------------------------------------------------------
382381
# Private sync helpers
383382
# ---------------------------------------------------------------------------

src/ndi/cloud/sync/operations.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -477,9 +477,7 @@ def twoWaySync(
477477
failed.append(doc_id)
478478

479479
# 4. Download remote-only docs
480-
docs, dl_failed = downloadNdiDocuments(
481-
cloud_dataset_id, remote_ids, to_download, client=client
482-
)
480+
docs, dl_failed = downloadNdiDocuments(cloud_dataset_id, remote_ids, to_download, client=client)
483481
saved = _save_downloaded_docs(ds_path, docs)
484482
report["downloaded"] = saved
485483
failed.extend(dl_failed)

tests/test_cloud_live.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,8 @@ def _cleanup_stale_pytest_datasets(client, cloud_config):
207207
result = listDatasets(cloud_config.org_id, client=client)
208208
datasets = result.get("datasets", [])
209209
stale = [
210-
ds for ds in datasets
210+
ds
211+
for ds in datasets
211212
if ds.get("name", "").startswith("NDI_PYTEST") and ds.get("_id", ds.get("id", ""))
212213
]
213214
if stale:

0 commit comments

Comments
 (0)