Registry / data / acryl-datahub-actions

acryl-datahub-actions

library1.6.0.3pypypiunverified

An action framework for reacting to real-time changes in DataHub, including entity change events and metadata change sync. Current version is 1.5.0.14, but the GitHub releases lag behind; the main git version is v0.2.1. The library is actively maintained by Acryl Data.

data devops workflow

pip install acryl-datahub-actions

github ↗package ↗homepage ↗docs ↗changelog ↗

INSTALL

IMPORT

SIG · ACRYL-DATAHUB-ACTI

acryl-datahub-actions

datapythonv1.6.0.3

Install

35.0s avg

Import

—

Disk

670MB

Pass rate

3/ 10

Env Coverage3 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v1.6.0.3 · pip install

no network on importno background threads

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

glibc

py 3.10

✕ build_error

✓ 39.6s

py 3.11

✕ build_error

✓ 35.5s

py 3.12

✕ build_error

✓ 29.9s

py 3.13

✕ build_error

1/2 runs

py 3.9

✕ build_error

1/2 runs

670MB installed

● package 670MB

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

MetadataChangeSyncAction

✓ from datahub_actions.action.metadata_change_sync import MetadataChangeSyncAction

✗ from datahub_actions.action.metadata_change_sync import MetadataChangeSyncAction

Minimal pipeline connecting DataHub source to DataHub sink with no actions.

from datahub_actions.pipeline import Pipeline from datahub_actions.source.datahub_source import DatahubSource from datahub_actions.sink.datahub_sink import DatahubSink import os # Configure a simple pipeline that logs events pipeline = Pipeline( source=DatahubSource( host=os.environ.get('DATAHUB_GMS_HOST', 'http://localhost:8080'), token=os.environ.get('DATAHUB_GMS_TOKEN', '') ), sink=DatahubSink( host=os.environ.get('DATAHUB_GMS_HOST', 'http://localhost:8080'), token=os.environ.get('DATAHUB_GMS_TOKEN', '') ), actions=[] ) pipeline.run()

Debug

Known issues

deprecatedThe v0.1.8 release has a known issue: missing tenacity dependency causing UnboundVariable exceptions.

fix

Upgrade to v0.1.10 or later, or manually install tenacity: pip install tenacity

affects: 0.1.8

breakingThe v0.2.0 release restructured imports; Action base class moved from top-level to submodule.

fix

Use from datahub_actions.action.action import Action instead of from datahub_actions import Action

affects: >=0.2.0

gotchaMany action classes require deep nested import paths; not exported from package root.

fix

Inspect the package's submodules for correct paths, e.g., datahub_actions.action.metadata_change_sync.

affects: >=0.1.0

deprecatedThe old pattern using DatahubRestSink and DatahubRestSource is deprecated in favor of DatahubSink/DatahubSource.

fix

Use DatahubSource and DatahubSink (from datahub_actions.source and .sink).

affects: >=0.2.0

Upgrade

Version history

1.6.0.3latest on PyPI · released Jun 15, 2026

Audit

Dependencies

acryl-datahubrequiredCore DataHub SDK; required for event types

confluent-kafkarequiredKafka consumer for event ingestion

tenacityrequiredRetry logic; missing in v0.1.8

Agent activity

77 hits · last 30 days

node

Perplexity

OpenAI (training)

Resources

githubhttps://github.com/acryldata/datahub-actions ↗

packagehttps://pypi.org/project/acryl-datahub-actions/ ↗

homepagehttps://docs.datahub.com/ ↗

docshttps://docs.datahub.com/docs/actions ↗

changeloghttps://github.com/acryldata/datahub-actions/releases ↗