Revert "add log.error() calls to wfi and neo4j_driver files"

lanl · Mar 20, 2024 · 62b01de · 62b01de
1 parent 63ea393
commit 62b01de
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 15 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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)