fyxthon

Author: shortcuts

templates/python/api.mustache

@@ -15,6 +15,7 @@ from algoliasearch.search.models import (
 from algoliasearch.ingestion.models import (WatchResponse)
 from algoliasearch.ingestion.config import IngestionConfig
 from algoliasearch.ingestion.client import (IngestionClient, IngestionClientSync)
+from algoliasearch.ingestion.models import Action as IngestionAction
 {{/isSearchClient}}
 {{#isIngestionClient}}
 from algoliasearch.ingestion.models import (Action, WatchResponse, Event, PushTaskRecords)

templates/python/search_helpers.mustache

@@ -305,7 +305,7 @@
         """
         if self._ingestion_transporter is None:
             raise ValueError("`region` must be provided at client instantiation before calling this method.")
-        return {{^isSyncClient}}await {{/isSyncClient}}self._ingestion_transporter.chunked_push(index_name=index_name, objects=objects, action=Action.ADDOBJECT, wait_for_tasks=wait_for_tasks, batch_size=batch_size, request_options=request_options)
+        return {{^isSyncClient}}await {{/isSyncClient}}self._ingestion_transporter.chunked_push(index_name=index_name, objects=objects, action=IngestionAction.ADDOBJECT, wait_for_tasks=wait_for_tasks, batch_size=batch_size, request_options=request_options)
 
     {{^isSyncClient}}async {{/isSyncClient}}def delete_objects(
         self,
@@ -348,7 +348,7 @@
         """
         if self._ingestion_transporter is None:
             raise ValueError("`region` must be provided at client instantiation before calling this method.")
-        return {{^isSyncClient}}await {{/isSyncClient}}self._ingestion_transporter.chunked_push(index_name=index_name, objects=objects, action=Action.PARTIALUPDATEOBJECT if create_if_not_exists else Action.PARTIALUPDATEOBJECTNOCREATE, wait_for_tasks=wait_for_tasks, batch_size=batch_size, request_options=request_options)
+        return {{^isSyncClient}}await {{/isSyncClient}}self._ingestion_transporter.chunked_push(index_name=index_name, objects=objects, action=IngestionAction.PARTIALUPDATEOBJECT if create_if_not_exists else IngestionAction.PARTIALUPDATEOBJECTNOCREATE, wait_for_tasks=wait_for_tasks, batch_size=batch_size, request_options=request_options)
 
     {{^isSyncClient}}async {{/isSyncClient}}def chunked_batch(
         self,