'Test DataProcClusterOperator instance is properly initialized.'

def test_init(self):

    for (suffix, dataproc_operator) in enumerate(self.dataproc_operators):
        self.assertEqual(dataproc_operator.cluster_name, CLUSTER_NAME)
        self.assertEqual(dataproc_operator.project_id, PROJECT_ID)
        self.assertEqual(dataproc_operator.num_workers, NUM_WORKERS)
        self.assertEqual(dataproc_operator.zone, ZONE)
        self.assertEqual(dataproc_operator.storage_bucket, STORAGE_BUCKET)
        self.assertEqual(dataproc_operator.image_version, IMAGE_VERSION)
        self.assertEqual(dataproc_operator.master_machine_type, MASTER_MACHINE_TYPE)
        self.assertEqual(dataproc_operator.master_disk_size, MASTER_DISK_SIZE)
        self.assertEqual(dataproc_operator.worker_machine_type, WORKER_MACHINE_TYPE)
        self.assertEqual(dataproc_operator.worker_disk_size, WORKER_DISK_SIZE)
        self.assertEqual(dataproc_operator.num_preemptible_workers, NUM_PREEMPTIBLE_WORKERS)
        self.assertEqual(dataproc_operator.labels, self.labels[suffix])
