destinations.impl.qdrant.qdrant_client
QdrantClient Objects
class QdrantClient(JobClientBase, WithStateSync)
Qdrant Destination Handler
drop_storage
def drop_storage() -> None
Drop the dataset from the Qdrant instance.
Deletes all collections in the dataset and all data associated. Deletes the sentinel collection.
If dataset name was not provided, it deletes all the tables in the current schema
get_stored_state
def get_stored_state(pipeline_name: str) -> Optional[StateInfo]
Loads compressed state from destination storage By finding a load id that was completed
get_stored_schema
def get_stored_schema() -> Optional[StorageSchemaInfo]
Retrieves newest schema from destination storage