airflow/contrib/hooks/gcp_vision_hook.py
def create_product_set(
        self,
        location,
        product_set,
        project_id=None,
        product_set_id=None,
        retry=None,
        timeout=None,
        metadata=None,
    ):
        """
        For the documentation see:
        :class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetCreateOperator`
        """
        client = self.get_conn()
        parent = ProductSearchClient.location_path(project_id, location)
        self.log.info('Creating a new ProductSet under the parent: %s', parent)
        response = client.create_product_set(
            parent=parent,
            product_set=product_set,
            product_set_id=product_set_id,
            retry=retry,
            timeout=timeout,
            metadata=metadata,
        )
        self.log.info('ProductSet created: %s', response.name if response else '')
        self.log.debug('ProductSet created:\n%s', response)

        if not product_set_id:
            # Product set id was generated by the API
            product_set_id = self._get_autogenerated_id(response)
            self.log.info('Extracted autogenerated ProductSet ID from the response: %s', product_set_id)

        return product_set_id
def create_product_set(
        self,
        location,
        product_set,
        project_id=None,
        product_set_id=None,
        retry=None,
        timeout=None,
        metadata=None,
    ):
        """
        For the documentation see:
        :class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetCreateOperator`
        """
        client = self.get_conn()
        parent = ProductSearchClient.location_path(project_id, location)
        self.log.info('Creating a new ProductSet under the parent: %s', parent)
        response = client.create_product_set(
            parent=parent,
            product_set=product_set,
            product_set_id=product_set_id,
            retry=retry,
            timeout=timeout,
            metadata=metadata,
        )
        self.log.info('ProductSet created: %s', response.name if response else '')
        self.log.debug('ProductSet created:\n%s', response)

        if not product_set_id:
            # Product set id was generated by the API
            product_set_id = self._get_autogenerated_id(response)
            self.log.info('Extracted autogenerated ProductSet ID from the response: %s', product_set_id)

        return product_set_id
def create_product_set ( self , location , product_set , project_id = None , product_set_id = None , retry = None , timeout = None , metadata = None , ) : client = self . get_conn ( ) parent = ProductSearchClient . location_path ( project_id , location ) self . log . info ( 'Creating a new ProductSet under the parent: %s' , parent ) response = client . create_product_set ( parent = parent , product_set = product_set , product_set_id = product_set_id , retry = retry , timeout = timeout , metadata = metadata , ) self . log . info ( 'ProductSet created: %s' , response . name if response else '' ) self . log . debug ( 'ProductSet created:\n%s' , response ) if not product_set_id : # Product set id was generated by the API product_set_id = self . _get_autogenerated_id ( response ) self . log . info ( 'Extracted autogenerated ProductSet ID from the response: %s' , product_set_id ) return product_set_id
For the documentation see:
        :class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetCreateOperator`
For the documentation see : : class : ~airflow . contrib . operators . gcp_vision_operator . CloudVisionProductSetCreateOperator