def create_stream()

in src/aws_interfaces/iot_interface.py [0:0]

• 20 lines of code
• 2 McCabe index (conditional complexity)

    def create_stream(self, streamId, fileId, bucket, key, role_arn):
        logging.info('create_stream streamId %s with fileId %s', streamId, fileId)
        try:
            response = self.client.create_stream(
                streamId=streamId,
                description='testing',
                files=[
                    {
                        "fileId": fileId,
                        "s3Location": {
                            "bucket": bucket,
                            "key": key
                        }
                    }
                ],
                roleArn=role_arn
            )
        except ClientError as e:
            return False, str(e)
        return True, None