Skip to content

Commit 2ec3bf4

Browse files
committed
Creates the connection_manifest_path if it does not already exist
1 parent d0a2186 commit 2ec3bf4

2 files changed

Lines changed: 5 additions & 4 deletions

File tree

receptor/receptor.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,10 @@ def __init__(self, config, node_id=None, router_cls=None,
2222
self.work_manager = (work_manager_cls or WorkManager)(self)
2323
self.connections = dict()
2424
self.controller_connections = []
25-
self.connection_manifest_path = os.path.join(self.config.default_data_dir,
26-
self.node_id,
27-
"connection_manifest")
25+
self.base_path = os.path.join(self.config.default_data_dir, self.node_id)
26+
if not os.path.exists(self.base_path):
27+
os.mkdir(os.path.join(self.config.default_data_dir, self.node_id))
28+
self.connection_manifest_path = os.path.join(self.base_path, "connection_manifest")
2829
self.stop = False
2930

3031
def _find_node_id(self):

test/integration/test_main.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import pytest
22
import receptor
33
from receptor.config import ReceptorConfig
4-
from receptor import Receptor
4+
from receptor.receptor import Receptor
55
from receptor.node import mainloop
66
import socket
77
import asyncio

0 commit comments

Comments
 (0)