diff --git a/paraffin/cli.py b/paraffin/cli.py index cffeb54..e743d8e 100644 --- a/paraffin/cli.py +++ b/paraffin/cli.py @@ -1,3 +1,4 @@ +import os import subprocess import time import typing as t @@ -5,7 +6,6 @@ import git import networkx as nx import typer -import os from paraffin.submit import submit_node_graph from paraffin.utils import ( diff --git a/paraffin/worker/__init__.py b/paraffin/worker/__init__.py index cdb482c..c1da255 100644 --- a/paraffin/worker/__init__.py +++ b/paraffin/worker/__init__.py @@ -1,11 +1,11 @@ import logging +import os import pathlib import random import subprocess import time -import git -import os +import git from celery import Celery log = logging.getLogger(__name__) @@ -92,7 +92,6 @@ def repro(self, *args, name: str, branch: str, origin: str | None, commit: bool) # TODO: what about dvc credentials? raise RuntimeError("Not in a git repository") - popen = subprocess.Popen( ["dvc", "repro", "--single-item", name], stdout=subprocess.PIPE,