diff --git a/import-automation/executor/app/executor/import_executor.py b/import-automation/executor/app/executor/import_executor.py index ed54d2b5ed..bf49bfeaa4 100644 --- a/import-automation/executor/app/executor/import_executor.py +++ b/import-automation/executor/app/executor/import_executor.py @@ -36,8 +36,8 @@ from app.service import import_service # Email address for status messages. -_SUCCESS_EMAIL_ADDR = 'datacommons+release@google.com' -_FAILURE_EMAIL_ADDR = 'datacommons-alerts+importautomation@google.com' +_DEBUG_EMAIL_ADDR = 'datacommons-debug+imports@google.com' +_ALERT_EMAIL_ADDR = 'datacommons-alerts+imports@google.com' _SEE_LOGS_MESSAGE = ( 'Please find logs in the Logs Explorer of the GCP project associated with' @@ -300,7 +300,7 @@ def _import_one( self.notifier.send( subject=f'Import Automation Success - {import_name}', body=msg, - receiver_addresses=[_SUCCESS_EMAIL_ADDR], + receiver_addresses=[_DEBUG_EMAIL_ADDR], ) except Exception as exc: @@ -312,7 +312,7 @@ def _import_one( self.notifier.send( subject=f'Import Automation Failure - {import_name}', body=msg, - receiver_addresses=[_FAILURE_EMAIL_ADDR], + receiver_addresses=[_ALERT_EMAIL_ADDR, _DEBUG_EMAIL_ADDR], ) raise exc