We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b7a5534 commit a809fc9Copy full SHA for a809fc9
tasks/dataflow/graph_loader.py
@@ -58,6 +58,8 @@ def __init__(
58
require_inst2vec: bool = False,
59
max_queue_size: int = 512,
60
):
61
+ self._stopped = False
62
+
63
self.graph_path = path / epoch_pb2.EpochType.Name(epoch_type).lower()
64
if not self.graph_path.is_dir():
65
raise FileNotFoundError(str(self.graph_path))
@@ -88,7 +90,6 @@ def __init__(
88
90
self._outq = Queue(maxsize=max_queue_size)
89
91
self._thread = threading.Thread(target=self._Worker)
92
self._thread.start()
- self._stopped = False
93
94
def Stop(self):
95
if self._stopped:
0 commit comments