skit_pipelines.pipelines.fetch_tagged_data_from_labelstore package

Module contents

fetch_tagged_data_from_labelstore(flow_id: str, start_date: str = '', end_date: str = '', limit: int = 2000, notify: str = '', channel: str = '', slack_thread: str = '', data_labels: str = '')[source]

A pipeline aimed at querying intent, entity, and transcriptions that happen across Skit

Example payload to invoke via slack integrations:

@charon run fetch_tagged_data_from_labelstore

{
    "flow_id": "294",
    "limit": 20,
    "start_date": "2022-11-12",
    "end_date": "2022-11-16",
    "data_labels": "Client, Live"
}
Parameters

  • flow_id (str) – The id of the flow from which annotated data should be queried

  • start_date (str, optional) – The start date range (YYYY-MM-DD) to filter tagged data. defaults to yesterday

  • end_date (str, optional) – The end date range (YYYY-MM-DD) to filter tagged data, defaults to today

  • limit (int, optional) – Number of annotations to fetch, defaults to 2000

  • notify (str, optional) – Whether to send a slack notification, defaults to “”

  • channel (str, optional) – The slack channel to send the notification, defaults to “”

  • slack_thread (float, optional) – The slack thread to send the notification, defaults to “”

  • data_labels (str, optional) – Comma seperated data labels to filter, defaults to “”