delete telemetry (#129)

* removes telemetry

* update

* lint

* update

* fix

Author: edublancas

.github/workflows/ci-mac.yml

@@ -12,7 +12,7 @@ jobs:
     runs-on: macos-latest
     strategy:
       matrix:
-        python-version: [3.7, 3.8, 3.9]
+        python-version: [3.9]
 
     steps:
     - uses: actions/checkout@v2

.github/workflows/ci-windows.yml

@@ -12,7 +12,7 @@ jobs:
     runs-on: windows-latest
     strategy:
       matrix:
-        python-version: [3.7, 3.8, 3.9]
+        python-version: [3.9]
 
     steps:
     - uses: actions/checkout@v2

.github/workflows/ci.yml

@@ -13,7 +13,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        python-version: [3.7, 3.8, 3.9]
+        python-version: [3.9]
 
     steps:
     - uses: actions/checkout@v2

src/soopervisor/abc.py

@@ -1,6 +1,7 @@
 """
 Abstract classes that define the protocol for all exporters
 """
+
 import click
 import abc
 from pathlib import Path

src/soopervisor/airflow/export.py

@@ -1,6 +1,7 @@
 """
 Export a Ploomber DAG to Airflow
 """
+
 import json
 import os
 from pathlib import Path

src/soopervisor/argo/export.py

@@ -1,6 +1,7 @@
 """
 Export to Argo Workflows
 """
+
 from pathlib import Path
 
 import click

src/soopervisor/aws/batch.py

@@ -1,6 +1,7 @@
 """
 Running pipelines on AWS Batch
 """
+
 import re
 from uuid import uuid4
 import os

src/soopervisor/aws/lambda_.py

@@ -1,6 +1,7 @@
 """
 Online DAG deployment using AWS Lambda
 """
+
 from pathlib import Path
 from ploomber.util import default
 from ploomber.io._commander import Commander

src/soopervisor/cli.py

@@ -6,7 +6,6 @@
 from soopervisor import config
 from soopervisor import exporter
 from soopervisor.enum import Backend, Mode
-from soopervisor.telemetry import telemetry
 
 
 @click.group()
@@ -39,34 +38,22 @@ def add(env_name, backend, preset):
     """
     backend = Backend(backend)
 
-    try:
-        if Path("soopervisor.yaml").exists():
-            cfg = yaml.safe_load(Path("soopervisor.yaml").read_text())
-            if env_name in cfg:
-                raise click.ClickException(
-                    f"A {env_name!r} section in the "
-                    "soopervisor.yaml configuration file "
-                    "already exists. Choose another name."
-                )
-        if Path(env_name).exists():
+    if Path("soopervisor.yaml").exists():
+        cfg = yaml.safe_load(Path("soopervisor.yaml").read_text())
+        if env_name in cfg:
             raise click.ClickException(
-                f"{env_name!r} already exists. Select a different name."
+                f"A {env_name!r} section in the "
+                "soopervisor.yaml configuration file "
+                "already exists. Choose another name."
             )
-    except Exception as e:
-        telemetry.log_api(
-            "soopervisor_add_error",
-            metadata={"type": backend.value, "env_name": env_name, "error": str(e)},
+    if Path(env_name).exists():
+        raise click.ClickException(
+            f"{env_name!r} already exists. Select a different name."
         )
-        raise
 
     Exporter = exporter.for_backend(backend)
     Exporter.new("soopervisor.yaml", env_name=env_name, preset=preset).add()
 
-    telemetry.log_api(
-        "soopervisor_add_success",
-        metadata={"type": backend.value, "env_name": env_name},
-    )
-
     click.echo(
         "Environment added, to export it:\n"
         f"\t $ soopervisor export {env_name}\n"
@@ -100,23 +87,8 @@ def export(
     """
     Export a target platform for execution/deployment
     """
-    input_args = {
-        "env_name": env_name,
-        "until_build": until_build,
-        "mode": mode,
-        "skip_tests": skip_tests,
-        "skip_docker": skip_docker,
-        "ignore_git": ignore_git,
-        "task": task,
-    }
-
     backend = Backend(config.get_backend(env_name))
 
-    telemetry.log_api(
-        "soopervisor_export_started",
-        metadata={"type": backend.value, "input_args": input_args},
-    )
-
     until = None
 
     if until_build:
@@ -129,27 +101,14 @@ def export(
 
     Exporter = exporter.for_backend(backend)
 
-    try:
-        Exporter.load("soopervisor.yaml", env_name=env_name, lazy_import=lazy).export(
-            mode=mode,
-            until=until,
-            skip_tests=skip_tests,
-            skip_docker=skip_docker,
-            ignore_git=ignore_git,
-            lazy_import=lazy,
-            task_name=task,
-        )
-
-    except Exception as e:
-        telemetry.log_api(
-            "soopervisor_export_error",
-            metadata={"type": backend.value, "input_args": input_args, "error": str(e)},
-        )
-        raise
-
-    telemetry.log_api(
-        "soopervisor_export_success",
-        metadata={"type": backend.value, "input_args": input_args},
+    Exporter.load("soopervisor.yaml", env_name=env_name, lazy_import=lazy).export(
+        mode=mode,
+        until=until,
+        skip_tests=skip_tests,
+        skip_docker=skip_docker,
+        ignore_git=ignore_git,
+        lazy_import=lazy,
+        task_name=task,
     )
 
 

src/soopervisor/commons/dag.py

@@ -1,6 +1,7 @@
 """
 Loading dags
 """
+
 from pathlib import Path
 
 from ploomber.constants import TaskStatus