dataraft.lake reference
Function signatures, arguments and examples, drawn directly from the documented package source.
assert_lakeExtension implementation helperassert_table_assetExtension implementation helperassert_writableExtension implementation helpercheck_pipelineExtension implementation helpercompose_candidateExtension implementation helperdr_backfillReplace date partitions over a bounded rangedr_check_deliveryCheck an expected business-date delivery, even when no ingest job randr_cleanupPreview or remove expired unpublished candidate tablesdr_compareCompare two published releases by business keydr_connect_lakeConnect a configured lakedr_disconnect_lakeClose a lake connectiondr_expire_snapshotsExpire DuckLake snapshots and reclaim scheduled filesdr_ingestCheck a delivery and publish an accepted raw releasedr_internal_acquire_lake_writerInternal family implementation interfacedr_internal_assert_lakeInternal family implementation interfacedr_internal_assert_table_assetInternal family implementation interfacedr_internal_assert_writableInternal family implementation interfacedr_internal_check_pipelineInternal family implementation interfacedr_internal_compose_candidateInternal family implementation interfacedr_internal_emit_eventInternal family implementation interfacedr_internal_execInternal family implementation interfacedr_internal_finish_runInternal family implementation interfacedr_internal_insert_metaInternal family implementation interfacedr_internal_land_sourceInternal family implementation interfacedr_internal_metaInternal family implementation interfacedr_internal_new_runInternal family implementation interfacedr_internal_persist_qualityInternal family implementation interfacedr_internal_publish_candidateInternal family implementation interfacedr_internal_publish_model_resultInternal family implementation interfacedr_internal_queryInternal family implementation interfacedr_internal_read_model_releaseInternal family implementation interfacedr_internal_read_release_sourceInternal family implementation interfacedr_internal_resolve_releaseInternal family implementation interfacedr_internal_with_execution_lakeInternal family implementation interfacedr_internal_with_model_lakeInternal family implementation interfacedr_interruptedIdentify interrupted runs without changing metadatadr_lake_configDefine a lake without opening a connectiondr_open_lakeOpen a local lake with sensible defaultsdr_product_stateRead product statedr_product_transitionsRead transition historydr_promoteTransition product statedr_read_releaseRead a published assetdr_recoverRecover explicitly selected abandoned runs and staging slotsdr_refresh_connectionRefresh a lake in the IDE Connections panedr_registerRegister a versioned definitiondr_registryRead framework metadatadr_registry_duckdbDefine metadata and storage configurationdr_releasesList published release historydr_source_releaseRead a pinned lake release as a product sourcedr_target_lakeChoose governed lake storage for a composed productdr_tblQuery a published immutable data releasedr_verify_releasesVerify stored release integritydr_write_dataWrite data with optional configurationemit_eventExtension implementation helperexecExtension implementation helperfinish_runExtension implementation helperinsert_metaExtension implementation helperland_sourceExtension implementation helpermetaExtension implementation helpernew_runExtension implementation helperpersist_qualityExtension implementation helperpublish_candidateExtension implementation helperpublish_model_resultExtension implementation helperqueryExtension implementation helperread_model_releaseExtension implementation helperread_release_sourceExtension implementation helperresolve_releaseExtension implementation helperwith_execution_lakeExtension implementation helperwith_model_lakeExtension implementation helper