Merge pull request #2079 from dandi/enh-logging-msgs

Add some .debug level messages in tasks upon no action to be performed

dandiapi/api/doi.py

@@ -82,3 +82,5 @@ def delete_doi(doi: str) -> None:
                 except requests.exceptions.HTTPError:
                     logger.exception('Failed to delete DOI %s', doi)
                     raise
+    else:
+        logger.debug('Skipping DOI deletion for %s since not configured', doi)

dandiapi/api/tasks/__init__.py

@@ -69,6 +69,8 @@ def validate_asset_metadata_task(asset_id: int) -> None:
     asset: Asset = Asset.objects.filter(id=asset_id, status=Asset.Status.PENDING).first()
     if asset:
         validate_asset_metadata(asset=asset)
+    else:
+        logger.debug('Asset %s not found or already validated', asset_id)
 
 
 @shared_task(soft_time_limit=30)

dandiapi/api/tasks/scheduled.py

@@ -81,6 +81,8 @@ def validate_pending_asset_metadata():
         logger.info('Found %s assets to validate', validatable_assets_count)
         for asset_id in throttled_iterator(validatable_assets.iterator()):
             validate_asset_metadata_task.delay(asset_id)
+    else:
+        logger.debug('Found no assets to validate')
 
 
 @shared_task(soft_time_limit=20)
@@ -101,6 +103,8 @@ def validate_draft_version_metadata():
             # Revalidation should be triggered every time a version is modified,
             # so now is a good time to write out the manifests as well.
             write_manifest_files.delay(draft_version_id)
+    else:
+        logger.debug('Found no versions to validate')
 
 
 @shared_task(soft_time_limit=20)
@@ -125,6 +129,11 @@ def refresh_materialized_view_search() -> None:
 
 def register_scheduled_tasks(sender: Celery, **kwargs):
     """Register tasks with a celery beat schedule."""
+    logger.info(
+        'Registering scheduled tasks for %s. ' 'DANDI_VALIDATION_JOB_INTERVAL is %s seconds.',
+        sender,
+        settings.DANDI_VALIDATION_JOB_INTERVAL,
+    )
     # Check for any draft versions that need validation every minute
     sender.add_periodic_task(
         timedelta(seconds=settings.DANDI_VALIDATION_JOB_INTERVAL),