Skip to content

Commit 81ad972

Browse files
improve logging display at connection
1 parent eef7e59 commit 81ad972

File tree

4 files changed

+24
-12
lines changed

4 files changed

+24
-12
lines changed

datajoint/connection.py

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
import pathlib
1313

1414
from .settings import config
15-
from . import errors
15+
from . import errors, __version__
1616
from .dependencies import Dependencies
1717
from .blob import pack, unpack
1818
from .hash import uuid_from_buffer
@@ -190,15 +190,20 @@ def __init__(self, host, user, password, port=None, init_fun=None, use_tls=None)
190190
self.conn_info["ssl_input"] = use_tls
191191
self.conn_info["host_input"] = host_input
192192
self.init_fun = init_fun
193-
logger.info("Connecting {user}@{host}:{port}".format(**self.conn_info))
194193
self._conn = None
195194
self._query_cache = None
196195
connect_host_hook(self)
197196
if self.is_connected:
198-
logger.info("Connected {user}@{host}:{port}".format(**self.conn_info))
197+
logger.info(
198+
"DataJoint {version} connected {user}@{host}:{port}".format(
199+
version=__version__, **self.conn_info
200+
)
201+
)
199202
self.connection_id = self.query("SELECT connection_id()").fetchone()[0]
200203
else:
201-
raise errors.LostConnectionError("Connection failed.")
204+
raise errors.LostConnectionError(
205+
"Connection failed {user}@{host}:{port}".format(**self.conn_info)
206+
)
202207
self._in_transaction = False
203208
self.schemas = dict()
204209
self.dependencies = Dependencies(self)

datajoint/schemas.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -482,8 +482,8 @@ def list_tables(self):
482482
return [
483483
t
484484
for d, t in (
485-
full_t.replace("`", "").split(".")
486-
for full_t in self.connection.dependencies.topo_sort()
485+
table_name.replace("`", "").split(".")
486+
for table_name in self.connection.dependencies.topo_sort()
487487
)
488488
if d == self.database
489489
]

datajoint/settings.py

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
"""
2-
Settings for DataJoint.
2+
Settings for DataJoint
33
"""
44

55
from contextlib import contextmanager
@@ -48,7 +48,8 @@
4848
"database.use_tls": None,
4949
"enable_python_native_blobs": True, # python-native/dj0 encoding support
5050
"add_hidden_timestamp": False,
51-
"filepath_checksum_size_limit": None, # file size limit for when to disable checksums
51+
# file size limit for when to disable checksums
52+
"filepath_checksum_size_limit": None,
5253
}
5354
)
5455

@@ -117,6 +118,7 @@ def load(self, filename):
117118
if filename is None:
118119
filename = LOCALCONFIG
119120
with open(filename, "r") as fid:
121+
logger.info(f"Reading dj.config from {filename}")
120122
self._conf.update(json.load(fid))
121123

122124
def save_local(self, verbose=False):
@@ -236,7 +238,8 @@ class __Config:
236238

237239
def __init__(self, *args, **kwargs):
238240
self._conf = dict(default)
239-
self._conf.update(dict(*args, **kwargs)) # use the free update to set keys
241+
# use the free update to set keys
242+
self._conf.update(dict(*args, **kwargs))
240243

241244
def __getitem__(self, key):
242245
return self._conf[key]
@@ -250,7 +253,9 @@ def __setitem__(self, key, value):
250253
valid_logging_levels = {"DEBUG", "INFO", "WARNING", "ERROR", "CRITICAL"}
251254
if key == "loglevel":
252255
if value not in valid_logging_levels:
253-
raise ValueError(f"{'value'} is not a valid logging value")
256+
raise ValueError(
257+
f"{'value'} is not a valid logging value {tuple(valid_logging_levels)}"
258+
)
254259
logger.setLevel(value)
255260

256261

@@ -292,6 +297,8 @@ def __setitem__(self, key, value):
292297
)
293298
if v is not None
294299
}
295-
config.update(mapping)
300+
if mapping:
301+
logger.info(f"Loaded settings {tuple(mapping)} from environment variables.")
302+
config.update(mapping)
296303

297304
logger.setLevel(log_levels[config["loglevel"]])

datajoint/version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
1-
__version__ = "0.14.3"
1+
__version__ = "0.14.4"
22

33
assert len(__version__) <= 10 # The log table limits version to the 10 characters

0 commit comments

Comments
 (0)