Remove unused imports

finic-ai · Aug 16, 2024 · ebd547c · ebd547c
1 parent 87651db
commit ebd547c
Show file tree

Hide file tree

Showing 6 changed files with 2 additions and 64 deletions.
diff --git a/workflow_job/src/node_runner/destinations.py b/workflow_job/src/node_runner/destinations.py
@@ -1,17 +1,7 @@
-import io
-from fastapi import UploadFile
 from typing import List, Optional, Tuple, Dict, Any
 from models.models import (
-    AppConfig,
-    User,
-    Workflow,
-    Edge,
-    Node,
-    NodeType,
     SnowflakeDestinationConfig,
 )
-import copy
-import numpy as np
 import snowflake.connector
 import pandas as pd
 from snowflake.connector.pandas_tools import write_pandas

diff --git a/workflow_job/src/node_runner/node_runner.py b/workflow_job/src/node_runner/node_runner.py
@@ -1,11 +1,5 @@
-import io
-from fastapi import UploadFile
-from typing import List, Optional, Tuple, Dict
+from typing import List, Dict
 from models import (
-    AppConfig,
-    User,
-    Workflow,
-    Edge,
     Node,
     NodeType,
     SourceNodeData,
@@ -14,17 +8,6 @@
     IntegrationType,
     TransformType,
 )
-from supabase import create_client, Client
-import os
-from storage3.utils import StorageException
-
-from io import StringIO
-from bs4 import BeautifulSoup
-import pandas as pd
-import httpx
-import datetime
-import tempfile
-import pdb
 from collections import deque
 from .transformations import run_mapping_node, run_python_node
 from .sources import run_gcs_source

diff --git a/workflow_job/src/node_runner/sources.py b/workflow_job/src/node_runner/sources.py
@@ -1,22 +1,13 @@
 import io
-from fastapi import UploadFile
 from typing import List, Optional, Tuple, Dict, Any
 from models.models import (
-    AppConfig,
-    User,
-    Workflow,
-    Edge,
-    Node,
-    NodeType,
-    SourceNodeData,
     GCSSourceConfig,
 )
 import copy
 import numpy as np
 from google.auth.transport.requests import Request
 from google.auth import jwt
 from urllib.parse import quote
-import requests
 import pandas as pd
 from google.cloud import storage
 from google.oauth2 import service_account

diff --git a/workflow_job/src/node_runner/transformations.py b/workflow_job/src/node_runner/transformations.py
@@ -1,19 +1,11 @@
-import io
-from fastapi import UploadFile
 from typing import List, Optional, Tuple, Dict, Any
 from models.models import (
-    AppConfig,
-    User,
-    Workflow,
-    Edge,
     Node,
     NodeType,
     MappingTransformConfig,
     PythonTransformConfig,
     JoinTransformConfig,
 )
-import copy
-import numpy as np
 import pandas as pd
 import subprocess
 import venv

diff --git a/workflow_job/src/workflow_database/database.py b/workflow_job/src/workflow_database/database.py
@@ -1,6 +1,5 @@
 import io
-from fastapi import UploadFile
-from typing import List, Optional, Tuple
+from typing import List, Optional
 from models.models import (
     AppConfig,
     User,
@@ -9,15 +8,8 @@
 )
 from supabase import create_client, Client
 import os
-from storage3.utils import StorageException
 
-from io import StringIO
-from bs4 import BeautifulSoup
-import pandas as pd
-import httpx
 import datetime
-import tempfile
-import pdb
 
 
 def get_supabase_timestamp(date: Optional[datetime.datetime] = None):

diff --git a/workflow_job/src/workflow_runner/workflow_runner.py b/workflow_job/src/workflow_runner/workflow_runner.py
@@ -1,5 +1,4 @@
 import io
-from fastapi import UploadFile
 from typing import List, Optional, Tuple, Dict
 from models.models import (
     AppConfig,
@@ -9,17 +8,8 @@
     WorkflowRunStatus,
     WorkflowRun,
 )
-from supabase import create_client, Client
-import os
-from storage3.utils import StorageException
 
-from io import StringIO
-from bs4 import BeautifulSoup
 import pandas as pd
-import httpx
-import datetime
-import tempfile
-import pdb
 from collections import deque
 from node_runner import NodeRunner
 from workflow_database import Database