diff --git a/kappa/event_source/s3.py b/kappa/event_source/s3.py index 9e5d527..03ceb0f 100644 --- a/kappa/event_source/s3.py +++ b/kappa/event_source/s3.py @@ -37,7 +37,7 @@ def add(self, function): { 'Id': self._make_notification_id(function.name), 'Events': [e for e in self._config['events']], - 'LambdaFunctionArn': '%s:%s' % (function.arn, function._context.environment), + 'LambdaFunctionArn': function.arn, } ] }