Showing
1 changed file
with
3 additions
and
3 deletions
... | @@ -54,7 +54,7 @@ class KinesisEventSource(EventSource): | ... | @@ -54,7 +54,7 @@ class KinesisEventSource(EventSource): |
54 | try: | 54 | try: |
55 | response = self._lambda.add_event_source( | 55 | response = self._lambda.add_event_source( |
56 | FunctionName=function.name, | 56 | FunctionName=function.name, |
57 | - Role=self.invoke_role_arn, | 57 | + Role=self._context.invoke_role_arn, |
58 | EventSource=self.arn, | 58 | EventSource=self.arn, |
59 | BatchSize=self.batch_size) | 59 | BatchSize=self.batch_size) |
60 | LOG.debug(response) | 60 | LOG.debug(response) |
... | @@ -88,9 +88,9 @@ class S3EventSource(EventSource): | ... | @@ -88,9 +88,9 @@ class S3EventSource(EventSource): |
88 | notification_spec = { | 88 | notification_spec = { |
89 | 'CloudFunctionConfiguration': { | 89 | 'CloudFunctionConfiguration': { |
90 | 'Id': self._make_notification_id(function.name), | 90 | 'Id': self._make_notification_id(function.name), |
91 | - 'Events': [e for e in self.config['events']], | 91 | + 'Events': [e for e in self._config['events']], |
92 | 'CloudFunction': function.arn(), | 92 | 'CloudFunction': function.arn(), |
93 | - 'InvocationRole': self.invoke_role_arn}} | 93 | + 'InvocationRole': self._context.invoke_role_arn}} |
94 | try: | 94 | try: |
95 | response = self._s3.put_bucket_notification( | 95 | response = self._s3.put_bucket_notification( |
96 | Bucket=self._get_bucket_name(), | 96 | Bucket=self._get_bucket_name(), | ... | ... |
-
Please register or login to post a comment