@GoogleCloudBaseHook.catch_http_exception<EOL><INDENT>@GoogleCloudBaseHook.fallback_to_default_project_id<EOL>def get_product(self, location, product_id, project_id=None, retry=None, timeout=None, metadata=None):<DEDENT>
client = self.get_conn()<EOL>name = ProductSearchClient.product_path(project_id, location, product_id)<EOL>self.log.info('<STR_LIT>', name)<EOL>response = client.get_product(name=name, retry=retry, timeout=timeout, metadata=metadata)<EOL>self.log.info('<STR_LIT>')<EOL>self.log.debug('<STR_LIT>', response)<EOL>return MessageToDict(response)<EOL>
For the documentation see:
:class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionProductGetOperator`