diff --git a/dandiapi/api/tasks/__init__.py b/dandiapi/api/tasks/__init__.py index 6c2449024..552f74b51 100644 --- a/dandiapi/api/tasks/__init__.py +++ b/dandiapi/api/tasks/__init__.py @@ -32,7 +32,7 @@ def calculate_sha256(blob_id: str) -> None: asset_blob.save() -@shared_task(soft_time_limit=60) +@shared_task(soft_time_limit=180) @atomic def write_manifest_files(version_id: int) -> None: version: Version = Version.objects.get(id=version_id) diff --git a/dandiapi/api/tasks/scheduled.py b/dandiapi/api/tasks/scheduled.py index 011043a40..1c6c6c0c3 100644 --- a/dandiapi/api/tasks/scheduled.py +++ b/dandiapi/api/tasks/scheduled.py @@ -43,7 +43,7 @@ def throttled_iterator(iterable: Iterable, max_per_second: int = 100) -> Iterabl time.sleep(1 / max_per_second) -@shared_task(soft_time_limit=10) +@shared_task(soft_time_limit=60) def aggregate_assets_summary_task(version_id: int): version = Version.objects.get(id=version_id) version_aggregate_assets_summary(version)