def create_redshift_processing_input()

in code/workflow/implementations/autopilot/bp_init_stage.py [0:0]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    def create_redshift_processing_input(self, redshift_dataset_defintion, name, base_dir):
        
        return {
            'InputName': name,
            'AppManaged': False,
            'RedshiftDatasetDefinition': {
                    'ClusterId': redshift_dataset_defintion["clusterIdentifier"],
                    'Database': redshift_dataset_defintion["database"],
                    'DbUser': redshift_dataset_defintion["dbUser"],
                    'QueryString': redshift_dataset_defintion["queryString"],
                    'ClusterRoleArn': redshift_dataset_defintion["unloadIamRole"],
                    'OutputS3Uri': redshift_dataset_defintion["s3OutputLocation"] + f"{name}/",
                     #'KmsKeyId': 'string',
                    'OutputFormat': redshift_dataset_defintion["outputFormat"].upper(),
                     #'OutputCompression': 'None'|'GZIP'|'BZIP2'|'ZSTD'|'SNAPPY'
                },
                'LocalPath': f"{base_dir}/{name}"
        }