dlt.pipeline.platform
dlthub beacon client. Also implements SupportsTracking for pipeline traces.
send_payload
def send_payload(payload_type: str,
payload: Any,
dsn: Optional[str] = None,
wait: bool = False) -> None
Sends a JSON payload to the dlthub beacon. Does nothing when the beacon is not configured.
Note: run identity comes from the DSN token, payload must not carry it.
Arguments:
payload_typestr - Beacon payload type, appended to the DSN as a path segment.payloadAny - JSON-serializable body.dsnstr - Beacon DSN, read from the active run context when not given.waitbool - Block until the request completes, e.g. before the process exits.