mirror of
https://github.com/MODSetter/SurfSense.git
synced 2026-06-10 20:35:17 +02:00
test(dropbox): update download failure return shape
This commit is contained in:
parent
b5aa41beb6
commit
bdd3728c5b
1 changed files with 6 additions and 6 deletions
|
|
@ -74,7 +74,7 @@ async def test_single_file_returns_one_connector_document(
|
|||
)
|
||||
|
||||
assert len(docs) == 1
|
||||
assert failed == 0
|
||||
assert failed == []
|
||||
assert docs[0].title == "test.txt"
|
||||
assert docs[0].unique_id == "f1"
|
||||
assert docs[0].document_type == DocumentType.DROPBOX_FILE
|
||||
|
|
@ -99,7 +99,7 @@ async def test_multiple_files_all_produce_documents(
|
|||
)
|
||||
|
||||
assert len(docs) == 3
|
||||
assert failed == 0
|
||||
assert failed == []
|
||||
assert {d.unique_id for d in docs} == {"f0", "f1", "f2"}
|
||||
|
||||
|
||||
|
|
@ -126,7 +126,7 @@ async def test_one_download_exception_does_not_block_others(
|
|||
)
|
||||
|
||||
assert len(docs) == 2
|
||||
assert failed == 1
|
||||
assert len(failed) == 1
|
||||
assert {d.unique_id for d in docs} == {"f0", "f2"}
|
||||
|
||||
|
||||
|
|
@ -152,7 +152,7 @@ async def test_etl_error_counts_as_download_failure(
|
|||
)
|
||||
|
||||
assert len(docs) == 1
|
||||
assert failed == 1
|
||||
assert len(failed) == 1
|
||||
|
||||
|
||||
# Slice 5: Semaphore bound
|
||||
|
|
@ -191,7 +191,7 @@ async def test_concurrency_bounded_by_semaphore(
|
|||
)
|
||||
|
||||
assert len(docs) == 6
|
||||
assert failed == 0
|
||||
assert failed == []
|
||||
assert peak <= 2, f"Peak concurrency was {peak}, expected <= 2"
|
||||
|
||||
|
||||
|
|
@ -230,7 +230,7 @@ async def test_heartbeat_fires_during_parallel_downloads(
|
|||
)
|
||||
|
||||
assert len(docs) == 3
|
||||
assert failed == 0
|
||||
assert failed == []
|
||||
assert len(heartbeat_calls) >= 1, "Heartbeat should have fired at least once"
|
||||
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue