Create shared run and job metadata | Describe input and output datasets | Emit the lifecycle | Add an extension facet | Configure delivery and authentication | Handle failures
Package: openlineage 0.1.0.9000
openlineage: Create and Emit 'OpenLineage' Events
Construct and validate run events that follow the 'OpenLineage' specification <https://openlineage.io/>. Model run lifecycles, datasets, and extensible facets with protocol-aware 'R' objects. Serialize events into deterministic JavaScript Object Notation (JSON) while preserving wire field names. Deliver events synchronously over Hypertext Transfer Protocol (HTTP) with authentication and retries, or use offline transports for local development and testing.
Authors:
openlineage_0.1.0.9000.tar.gz
openlineage_0.1.0.9000.zip(r-4.7-any)openlineage_0.1.0.9000.zip(r-4.6-any)openlineage_0.1.0.9000.zip(r-4.5-any)
openlineage_0.1.0.9000.tgz(r-4.6-any)openlineage_0.1.0.9000.tgz(r-4.5-any)
openlineage_0.1.0.9000.tar.gz(r-4.7-any)openlineage_0.1.0.9000.tar.gz(r-4.6-any)
openlineage_0.1.0.9000.tgz(r-4.6-emscripten)
manual.pdf |manual.html✨
DESCRIPTION |NEWS
card.svg |card.png
openlineage/json (API)
| # Install 'openlineage' in R: |
| install.packages('openlineage', repos = c('https://pedrobtz.r-universe.dev', 'https://cloud.r-project.org')) |
Bug tracker:https://github.com/pedrobtz/openlineage/issues
Pkgdown/docs site:https://pedrobtz.github.io
Last updated from:bd1f2547a1. Checks:9 OK. Indexed: yes.
| Target | Result | Time | Files | Syslog |
|---|---|---|---|---|
| linux-devel | OK | 133 | ||
| source / vignettes | OK | 183 | ||
| linux-release | OK | 130 | ||
| macos-release | OK | 73 | ||
| macos-oldrel | OK | 80 | ||
| windows-devel | OK | 78 | ||
| windows-release | OK | 73 | ||
| windows-oldrel | OK | 71 | ||
| wasm-release | OK | 112 |
Exports:AccumulatingTransportas_openlineage_listConsoleTransportDatasetDatasourceDatasetFacetEmissionPatternErrorMessageRunFacetHttpTransportInputDatasetInputStatisticsInputDatasetFacetJobJobTypeJobFacetnew_event_timenew_run_idNominalTimeRunFacetNoopTransportol_facetol_tagOPENLINEAGE_PRODUCEROPENLINEAGE_RUN_EVENT_SCHEMA_URLOPENLINEAGE_SCHEMA_URLOPENLINEAGE_SCHEMA_VERSIONOpenLineageClientOutputDatasetOutputStatisticsOutputDatasetFacetParentRunFacetProcessingEngineRunFacetRunRunEventRunStateSchemaDatasetFacetSchemaFieldSourceCodeLocationJobFacetSQLJobFacetTagsDatasetFacetTagsJobFacetTagsRunFacetto_openlineage_json
Dependencies:askpassclicurlgluehttr2jsonlitelifecyclemagrittropensslR6rlangS7sysuuidvctrswithr
Readme and manuals
Help Manual
| Help page | Topics |
|---|---|
| Create and Emit OpenLineage Events | openlineage-package openlineage |
| Convert an OpenLineage value to its wire representation | as_openlineage_list |
| Typed dataset facets | dataset_facets DatasourceDatasetFacet SchemaDatasetFacet SchemaField |
| OpenLineage datasets | Dataset datasets InputDataset OutputDataset |
| Synchronous HTTP transport | HttpTransport |
| Input and output statistics facets | InputStatisticsInputDatasetFacet io_statistics_facets OutputStatisticsOutputDatasetFacet |
| OpenLineage job | Job |
| Typed job facets | EmissionPattern JobTypeJobFacet job_facets SourceCodeLocationJobFacet SQLJobFacet |
| Local OpenLineage transports | AccumulatingTransport ConsoleTransport local_transports NoopTransport |
| Format an OpenLineage event time | new_event_time |
| Generate a run identifier | new_run_id |
| Create a generic OpenLineage facet | ol_facet |
| Create an OpenLineage tag | ol_tag |
| OpenLineage protocol constants | openlineage_constants OPENLINEAGE_PRODUCER OPENLINEAGE_RUN_EVENT_SCHEMA_URL OPENLINEAGE_SCHEMA_URL OPENLINEAGE_SCHEMA_VERSION |
| OpenLineage client | OpenLineageClient |
| OpenLineage run | Run |
| Typed run facets | ErrorMessageRunFacet NominalTimeRunFacet ParentRunFacet ProcessingEngineRunFacet run_facets |
| OpenLineage run event | RunEvent |
| OpenLineage run state | RunState |
| Typed tags facets | TagsDatasetFacet TagsJobFacet TagsRunFacet tags_facets |
| Serialize an OpenLineage value to JSON | to_openlineage_json |
