diff --git a/beeflow/common/gdb/gdb_driver.py b/beeflow/common/gdb/gdb_driver.py index 16d225590..2d372cbf4 100644 --- a/beeflow/common/gdb/gdb_driver.py +++ b/beeflow/common/gdb/gdb_driver.py @@ -1,9 +1,6 @@ """Abstract base class for the handling of workflow DAGs.""" from abc import ABC, abstractmethod -from beeflow.common import log as bee_logging - -log = bee_logging.setup(__name__) class GraphDatabaseDriver(ABC): diff --git a/beeflow/common/gdb/neo4j_cypher.py b/beeflow/common/gdb/neo4j_cypher.py index 8a48d0059..f8c8913a8 100644 --- a/beeflow/common/gdb/neo4j_cypher.py +++ b/beeflow/common/gdb/neo4j_cypher.py @@ -1,9 +1,6 @@ """Neo4j/Cypher transaction functions used by the Neo4jDriver class.""" from re import fullmatch -from beeflow.common import log as bee_logging - -log = bee_logging.setup(__name__) def create_workflow_node(tx, workflow): diff --git a/beeflow/common/gdb/neo4j_driver.py b/beeflow/common/gdb/neo4j_driver.py index 3b3222576..ba0d6f695 100644 --- a/beeflow/common/gdb/neo4j_driver.py +++ b/beeflow/common/gdb/neo4j_driver.py @@ -12,9 +12,6 @@ from beeflow.common.gdb import neo4j_cypher as tx from beeflow.common.wf_data import (Workflow, Task, Requirement, Hint, InputParameter, OutputParameter, StepInput, StepOutput) -from beeflow.common import log as bee_logging - -log = bee_logging.setup(__name__) # Default Neo4j authentication # We may want to instead get these from a config at some point @@ -54,7 +51,6 @@ def __init__(self, user=DEFAULT_USER, password=DEFAULT_PASSWORD, **kwargs): # Connect to the Neo4j database using the Neo4j proprietary driver self._driver = Neo4jDatabase.driver(uri, auth=(user, password)) except ServiceUnavailable as sue: - log.error("Neo4j database is unavailable") raise Neo4JNotRunning("Neo4j database is unavailable") from sue def initialize_workflow(self, workflow): diff --git a/beeflow/common/wf_interface.py b/beeflow/common/wf_interface.py index d34a790d5..f53f76725 100644 --- a/beeflow/common/wf_interface.py +++ b/beeflow/common/wf_interface.py @@ -4,9 +4,6 @@ """ import re -from beeflow.common import log as bee_logging - -log = bee_logging.setup(__name__) class WorkflowInterface: @@ -36,7 +33,6 @@ def initialize_workflow(self, workflow): :type workflow: Workflow """ if self.workflow_loaded(): - log.error("attempt to re-initialize existing workflow") raise RuntimeError("attempt to re-initialize existing workflow") if workflow.requirements is None: workflow.requirements = [] @@ -111,7 +107,6 @@ def restart_task(self, task, checkpoint_file): self.set_workflow_state("FAILED") return None else: - log.error("invalid task for checkpoint restart") raise ValueError("invalid task for checkpoint restart") new_task = task.copy(new_id=True)