@boto3_log
    def _create_ebs_volume(
        self, size=1, volume_type=EBSVolumeTypes.STANDARD.value,
        zone=None, iops=None
    ):
        if zone is None:
            zone = self.zone
        client = self.connection.meta.client
        if volume_type == EBSVolumeTypes.IO1.value:
            if iops is None:
                iops = IOPS_MIN_IOPS
            if size < IOPS_MIN_SIZE:
                size = IOPS_MIN_SIZE
            volume_data = client.create_volume(
                Size=size,
                AvailabilityZone=zone,
                VolumeType=volume_type,
                Iops=iops
            )
        else:
            volume_data = client.create_volume(
                Size=size,
                AvailabilityZone=zone,
                VolumeType=volume_type
            )
        volume = self.connection.Volume(volume_data['VolumeId'])
        volume.load()
        return volume
Set a task, or a task task to be directly downstream from the current
dataset/ETHPy150Open ClusterHQ/flocker/flocker/node/agents/ebs.py/EBSBlockDeviceAPI._create_ebs_volume--crossover with--dataset/ETHPy150Open airbnb/airflow/airflow/models.py/BaseOperator.set_downstream