fix: get_caids.py

broadinstitute · Sep 5, 2024 · 8112ab9 · 8112ab9
1 parent e313c00
commit 8112ab9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/data-pipeline/caids/get_caids.py b/data-pipeline/caids/get_caids.py
@@ -139,13 +139,13 @@ async def get_caids(sharded_vcf_url: str, output_url: str, *, parallelism: int =
 
             # Get list of VCF partitions.
             all_part_urls = [
-                await f.url() async for f in await fs.listfiles(sharded_vcf_url) if f.name().startswith("part-")
+                await f.url() async for f in await fs.listfiles(sharded_vcf_url) if f.basename().startswith("part-")
             ]
 
             # Get list of parts in output.
             try:
                 completed_part_urls = [
-                    await f.url() async for f in await fs.listfiles(output_url) if f.name().startswith("part-")
+                    await f.url() async for f in await fs.listfiles(output_url) if f.basename().startswith("part-")
                 ]
             except FileNotFoundError:
                 completed_part_urls = []