aboutsummaryrefslogtreecommitdiffstats
path: root/python/sandcrawler/ingest_fileset.py
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2021-12-11 20:22:10 -0800
committerBryan Newbold <bnewbold@archive.org>2021-12-11 20:22:10 -0800
commitc48eb50782854f95fa16fc0fdf5339c52c830314 (patch)
treee047ab7bef6e6b2189694adb3ea72ef5e9757935 /python/sandcrawler/ingest_fileset.py
parente5c021bfeb03c50924160616dc64d44617d45933 (diff)
downloadsandcrawler-c48eb50782854f95fa16fc0fdf5339c52c830314.tar.gz
sandcrawler-c48eb50782854f95fa16fc0fdf5339c52c830314.zip
fileset ingest: actually use spn2 CLI flag
Diffstat (limited to 'python/sandcrawler/ingest_fileset.py')
-rw-r--r--python/sandcrawler/ingest_fileset.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/python/sandcrawler/ingest_fileset.py b/python/sandcrawler/ingest_fileset.py
index 227f511..732a6ab 100644
--- a/python/sandcrawler/ingest_fileset.py
+++ b/python/sandcrawler/ingest_fileset.py
@@ -57,6 +57,7 @@ class IngestFilesetWorker(IngestFileWorker):
def __init__(self, sink: Optional[SandcrawlerWorker] = None, **kwargs):
super().__init__(sink=None, **kwargs)
+ self.try_spn2 = kwargs.get("try_spn2", True)
self.sink = sink
self.dataset_platform_helpers = {
"dataverse": DataverseHelper(),
@@ -67,8 +68,8 @@ class IngestFilesetWorker(IngestFileWorker):
self.dataset_strategy_archivers = {
IngestStrategy.ArchiveorgFileset: ArchiveorgFilesetStrategy(),
IngestStrategy.ArchiveorgFile: ArchiveorgFileStrategy(),
- IngestStrategy.WebFileset: WebFilesetStrategy(),
- IngestStrategy.WebFile: WebFileStrategy(),
+ IngestStrategy.WebFileset: WebFilesetStrategy(try_spn2=self.try_spn2),
+ IngestStrategy.WebFile: WebFileStrategy(try_spn2=self.try_spn2),
}
self.max_total_size = kwargs.get("max_total_size", 64 * 1024 * 1024 * 1024)