Skip to content

Commit 96e4e6e

Browse files
committed
add limit argument to stac crawler
1 parent 07a8df6 commit 96e4e6e

File tree

1 file changed

+4
-1
lines changed
  • geospaas_harvesting/crawlers

1 file changed

+4
-1
lines changed

geospaas_harvesting/crawlers/stac.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,21 +13,24 @@ class STACCrawler(Crawler):
1313
arguments.SequenceArgument('collections', required=False, default=None,
1414
contents_type=arguments.StringArgument),
1515
arguments.DictArgument('filter', required=False, default=None),
16+
arguments.IntegerArgument('limit', default=100),
1617
])
1718

1819
def __init__(self, **kwargs):
1920
super().__init__(**kwargs)
2021
self.url = kwargs['url']
2122
self.collections = kwargs['collections']
2223
self.filter = kwargs['filter']
23-
self._client = Client.open(self.url)
24+
self.limit = kwargs['limit']
25+
self._client = Client.open(self.url, timeout=300)
2426

2527
def crawl(self):
2628
items = self._client.search(
2729
collections=self.collections,
2830
intersects=self.location,
2931
datetime=self.time_range,
3032
filter=self.filter,
33+
limit=self.limit,
3134
).items_as_dicts()
3235

3336
for item in items:

0 commit comments

Comments
 (0)