airflow/contrib/hooks/gcp_vision_hook.py
def create_reference_image(
        self,
        location,
        product_id,
        reference_image,
        reference_image_id=None,
        project_id=None,
        retry=None,
        timeout=None,
        metadata=None,
    ):
        """
        For the documentation see:
        :py:class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionReferenceImageCreateOperator`
        """
        client = self.get_conn()
        self.log.info('Creating ReferenceImage')
        parent = ProductSearchClient.product_path(project=project_id, location=location, product=product_id)

        response = client.create_reference_image(
            parent=parent,
            reference_image=reference_image,
            reference_image_id=reference_image_id,
            retry=retry,
            timeout=timeout,
            metadata=metadata,
        )

        self.log.info('ReferenceImage created: %s', response.name if response else '')
        self.log.debug('ReferenceImage created:\n%s', response)

        if not reference_image_id:
            # Refernece image  id was generated by the API
            reference_image_id = self._get_autogenerated_id(response)
            self.log.info(
                'Extracted autogenerated ReferenceImage ID from the response: %s', reference_image_id
            )

        return reference_image_id
def create_reference_image(
        self,
        location,
        product_id,
        reference_image,
        reference_image_id=None,
        project_id=None,
        retry=None,
        timeout=None,
        metadata=None,
    ):
        """
        For the documentation see:
        :py:class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionReferenceImageCreateOperator`
        """
        client = self.get_conn()
        self.log.info('Creating ReferenceImage')
        parent = ProductSearchClient.product_path(project=project_id, location=location, product=product_id)

        response = client.create_reference_image(
            parent=parent,
            reference_image=reference_image,
            reference_image_id=reference_image_id,
            retry=retry,
            timeout=timeout,
            metadata=metadata,
        )

        self.log.info('ReferenceImage created: %s', response.name if response else '')
        self.log.debug('ReferenceImage created:\n%s', response)

        if not reference_image_id:
            # Refernece image  id was generated by the API
            reference_image_id = self._get_autogenerated_id(response)
            self.log.info(
                'Extracted autogenerated ReferenceImage ID from the response: %s', reference_image_id
            )

        return reference_image_id
def create_reference_image ( self , location , product_id , reference_image , reference_image_id = None , project_id = None , retry = None , timeout = None , metadata = None , ) : client = self . get_conn ( ) self . log . info ( 'Creating ReferenceImage' ) parent = ProductSearchClient . product_path ( project = project_id , location = location , product = product_id ) response = client . create_reference_image ( parent = parent , reference_image = reference_image , reference_image_id = reference_image_id , retry = retry , timeout = timeout , metadata = metadata , ) self . log . info ( 'ReferenceImage created: %s' , response . name if response else '' ) self . log . debug ( 'ReferenceImage created:\n%s' , response ) if not reference_image_id : # Refernece image  id was generated by the API reference_image_id = self . _get_autogenerated_id ( response ) self . log . info ( 'Extracted autogenerated ReferenceImage ID from the response: %s' , reference_image_id ) return reference_image_id
For the documentation see:
        :py:class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionReferenceImageCreateOperator`
For the documentation see : : py : class : ~airflow . contrib . operators . gcp_vision_operator . CloudVisionReferenceImageCreateOperator