airflow/contrib/hooks/gcp_vision_hook.py
def update_product_set(
        self,
        product_set,
        location=None,
        product_set_id=None,
        update_mask=None,
        project_id=None,
        retry=None,
        timeout=None,
        metadata=None,
    ):
        """
        For the documentation see:
        :class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetUpdateOperator`
        """
        client = self.get_conn()
        product_set = self.product_set_name_determiner.get_entity_with_name(
            product_set, product_set_id, location, project_id
        )
        self.log.info('Updating ProductSet: %s', product_set.name)
        response = client.update_product_set(
            product_set=product_set, update_mask=update_mask, retry=retry, timeout=timeout, metadata=metadata
        )
        self.log.info('ProductSet updated: %s', response.name if response else '')
        self.log.debug('ProductSet updated:\n%s', response)
        return MessageToDict(response)
def update_product_set(
        self,
        product_set,
        location=None,
        product_set_id=None,
        update_mask=None,
        project_id=None,
        retry=None,
        timeout=None,
        metadata=None,
    ):
        """
        For the documentation see:
        :class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetUpdateOperator`
        """
        client = self.get_conn()
        product_set = self.product_set_name_determiner.get_entity_with_name(
            product_set, product_set_id, location, project_id
        )
        self.log.info('Updating ProductSet: %s', product_set.name)
        response = client.update_product_set(
            product_set=product_set, update_mask=update_mask, retry=retry, timeout=timeout, metadata=metadata
        )
        self.log.info('ProductSet updated: %s', response.name if response else '')
        self.log.debug('ProductSet updated:\n%s', response)
        return MessageToDict(response)
def update_product_set ( self , product_set , location = None , product_set_id = None , update_mask = None , project_id = None , retry = None , timeout = None , metadata = None , ) : client = self . get_conn ( ) product_set = self . product_set_name_determiner . get_entity_with_name ( product_set , product_set_id , location , project_id ) self . log . info ( 'Updating ProductSet: %s' , product_set . name ) response = client . update_product_set ( product_set = product_set , update_mask = update_mask , retry = retry , timeout = timeout , metadata = metadata ) self . log . info ( 'ProductSet updated: %s' , response . name if response else '' ) self . log . debug ( 'ProductSet updated:\n%s' , response ) return MessageToDict ( response )
For the documentation see:
        :class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetUpdateOperator`
For the documentation see : : class : ~airflow . contrib . operators . gcp_vision_operator . CloudVisionProductSetUpdateOperator