Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

add usage type tracking #346

Merged
merged 1 commit into from
Dec 12, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion data_diff/__main__.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
from .databases import connect
from .parse_time import parse_time_before, UNITS_STR, ParseError
from .config import apply_config_from_file
from .tracking import disable_tracking
from .tracking import disable_tracking, set_entrypoint_name
from .version import __version__


Expand All @@ -32,6 +32,7 @@
"-": "red",
}

set_entrypoint_name("CLI")

def _remove_passwords_in_dict(d: dict):
for k, v in d.items():
Expand Down
9 changes: 9 additions & 0 deletions data_diff/tracking.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,8 @@ def _load_profile():
g_tracking_enabled = True
g_anonymous_id = None

entrypoint_name = "Python API"


def disable_tracking():
global g_tracking_enabled
Expand All @@ -50,6 +52,11 @@ def is_tracking_enabled():
return g_tracking_enabled


def set_entrypoint_name(s):
global entrypoint_name
entrypoint_name = s


def get_anonymous_id():
global g_anonymous_id
if g_anonymous_id is None:
Expand All @@ -70,6 +77,7 @@ def create_start_event_json(diff_options: Dict[str, Any]):
"python_version": f"{platform.python_version()}/{platform.python_implementation()}",
"diff_options": diff_options,
"data_diff_version:": __version__,
"entrypoint_name": entrypoint_name,
},
}

Expand Down Expand Up @@ -99,6 +107,7 @@ def create_end_event_json(
"diff_rows_cnt": diff_count,
"error_message": error,
"data_diff_version:": __version__,
"entrypoint_name": entrypoint_name,
},
}

Expand Down