This module contains a Segment Hook which allows you to connect to your Segment account, retrieve data from it or write to that file.

NOTE: this hook also relies on the Segment analytics package:

Module Contents

class airflow.contrib.hooks.segment_hook.SegmentHook(segment_conn_id='segment_default', segment_debug_mode=False, *args, **kwargs)[source]

Bases: airflow.hooks.base_hook.BaseHook

on_error(self, error, items)[source]

Handles error callbacks when using Segment with segment_debug_mode set to True

Was this entry helpful?