def run_benchmark_query()

in redshift_benchmark/redshiftBenchmarkStack.py [0:0]

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

    def run_benchmark_query(self,job_name,mode):
        return glue.CfnJob(
            self,
            job_name,
            role=self.glue_job_role.role_arn,
            max_capacity=0.0625,
            name = job_name,
            default_arguments = {
                 '--dbname':   self.dbname,
                 '--username': self.username,
                 '--password': self.password,
                 '--host': self.host,
                 '--port': self.port,
                 '--mode':mode,
                 '--sql_script_bucket': self.s3_bucket,
                 '--sql_script_key':'redshift_script/tpcds_queries/',
                 '--num_runs':self.num_runs,
                 '--num_files':self.num_files,
                 '--parallel_level':self.parallel_level
                 #'--extra-py-files':'s3://'+self.s3_bucket+'/glue_script/DBUtils-2.0.2-py3-none-any.whl,s3://'+self.s3_bucket+'/glue_script/psycopg2-2.9.1-cp36-cp36m-linux_x86_64.whl '
                 },
            tags={"project":"redshift-benchmark"},
            command=glue.CfnJob.JobCommandProperty(
                name="pythonshell",
                script_location="s3://"+self.s3_bucket+"/glue_script/run_redshift_benchmark.py",
                python_version = "3"
            )
        )