floe-lineage-marquez 0.1.0a1

Marquez lineage backend plugin for floe - OpenLineage reference implementation

floe-lineage-marquez

Marquez lineage backend plugin for floe - OpenLineage reference implementation for data lineage.

Overview

This plugin provides a MarquezLineageBackendPlugin that configures OpenLineage HTTP transport to send lineage events to a Marquez deployment. This is recommended for:

• Self-hosted data lineage tracking
• OpenLineage reference implementation
• Integration with existing Marquez infrastructure

Installation

pip install floe-lineage-marquez

Usage

Via manifest.yaml (Recommended)

# manifest.yaml
plugins:
  lineage_backend: marquez

Programmatic Usage

from floe_lineage_marquez import MarquezLineageBackendPlugin

plugin = MarquezLineageBackendPlugin(
    url="https://marquez:5000",
    api_key="optional-api-key"  # pragma: allowlist secret
)
# Plugin will be loaded automatically by LineageProvider

Configuration

The Marquez plugin configures OpenLineage HTTP transport:

• Default endpoint: marquez:5000 (HTTPS)
• Protocol: HTTPS/REST (HTTP for localhost development only)
• API endpoint: /api/v1/lineage

For production, configure:

• url: Marquez API base URL (use HTTPS)
• api_key: Optional authentication

Security

HTTPS Enforcement: By default, only HTTPS URLs are accepted (except for localhost). HTTP is allowed for localhost, 127.0.0.1, and ::1 for local development.

Development Override: To use HTTP with non-localhost URLs in development environments:

export FLOE_ALLOW_INSECURE_HTTP=true

Warning: Never use this in production. The plugin logs a CRITICAL warning when this override is active.

PostgreSQL Credentials: The get_helm_values() method uses Kubernetes Secrets via Bitnami's existingSecret pattern. Create a secret before deploying:

# Create the required Kubernetes secret
kubectl create secret generic marquez-postgresql-credentials \
  --from-literal=postgres-password='<your-admin-password>' \
  --from-literal=password='<your-user-password>'

Helm Deployment

The plugin provides Helm values for self-hosted deployment:

plugin = MarquezLineageBackendPlugin()
helm_values = plugin.get_helm_values()
# Returns Marquez + PostgreSQL chart values

Requirements

• Python 3.10+
• floe-core >= 0.1.0

Related

• Marquez - OpenLineage reference implementation
• OpenLineage - Open standard for data lineage

License

Apache-2.0