def __parse_spark_arguments()

in liminal/runners/airflow/tasks/spark.py [0:0]

• 5 lines of code
• 5 McCabe index (conditional complexity)

    def __parse_spark_arguments(self, spark_arguments):
        spark_arguments = {x[0]: x[1] for x in spark_arguments.items() if x[1]}

        return self.__interleaving(
            [f'--{k}' for k in spark_arguments.keys() if spark_arguments[k]], spark_arguments.values()
        )