# Example of disabling telemetry via environment variable
TELEMETRY_ENABLED=false

@dataclass
class Event:
    """Represents a telemetry event."""

    name: str
    data: Dict
    client_id: str = field(default_factory=lambda: str(TelemetryConfig.generate_client_id()))

@dataclass
class TelemetryData:
    """Class representing telemetry data for data processing jobs.

    This class captures various metrics and statistics about the execution of data processing jobs,
    including job configuration, execution time, and outcome summaries.
    """

def _send_telemetry_event(self):
    """Send telemetry data for the completed job.

    Collects and sends job metrics and error information to the analytics service.
    """
    telemetry_data = TelemetryData(
        job_id=self.config.master_job_id,
        target_reached=False,
        run_mode=self.config.run_mode,
        run_time_platform=get_platform_name(),
        num_inputs=self.input_data_queue.qsize(),
        library_version=__version__,  # Using the version here
        config={
            "batch_size": self.config.batch_size,
            "target_count": self.config.target_count,
            "dead_queue_threshold": self.config.dead_queue_threshold,
            "max_concurrency": self.config.max_concurrency,
            "task_runner_timeout": self.config.task_runner_timeout,
            "job_run_stop_threshold": self.config.job_run_stop_threshold,
        },
        error_summary={
            "err": str(self.err),
        },
    )
    if self.job_manager:
        telemetry_data.count_summary = {
            "completed": self.job_manager.completed_count,
            "failed": self.job_manager.failed_count,
            "filtered": self.job_manager.filtered_count,
        }
    self._analytics.capture_event(Event(name="data_factory_job_complete", data=asdict(telemetry_data)))

def capture_event(self, event: Event) -> None:
    """Capture an event with the analytics service."""
    if not self.settings.active:
        return

    try:
        self.client.capture(event.client_id, event.name, event.data)
        if self.settings.verbose:
            print(f"[telemetry] Captured event: {event.name} with data: {event.data}")
    except Exception as e:
        print(f"Failed to send telemetry event: {e}")

@staticmethod
def generate_client_id() -> UUID:
    """Generate or retrieve a unique client identifier."""
    config_path = path.join(path.expanduser(APP_DATA_DIR), ".starfish_config")
    makedirs(path.dirname(config_path), exist_ok=True)

    if path.exists(config_path):
        with open(config_path) as f:
            return UUID(f.read().strip())

    new_id = uuid4()
    with open(config_path, "w") as f:
        f.write(str(new_id))
    return new_id