Skip to content

Commit 998fa3a

Browse files
authored
Merge pull request #44 from jelu/srv-node
Server, node
2 parents 791f82d + 62c7d9d commit 998fa3a

File tree

4 files changed

+162
-153
lines changed

4 files changed

+162
-153
lines changed

dsc_datatool/__init__.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,15 @@ def main():
258258
log_level = 0
259259
logging.basicConfig(format='%(asctime)s %(levelname)s %(module)s: %(message)s', level=log_level, stream=sys.stderr)
260260

261+
if isinstance(args.server, list):
262+
args.server = ' '.join(args.server)
263+
elif not isinstance(args.server, str):
264+
raise Exception('Invalid argument for --server: %r' % args.server)
265+
if isinstance(args.node, list):
266+
args.node = ' '.join(args.node)
267+
elif not isinstance(args.node, str):
268+
raise Exception('Invalid argument for --node: %r' % args.node)
269+
261270
generators = []
262271
if args.generator:
263272
for arg in args.generator:

dsc_datatool/output/influxdb.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
import sys
1212
import atexit
1313

14-
from dsc_datatool import Output
14+
from dsc_datatool import Output,args
1515

1616

1717
_re = re.compile(r'([,=\s])')
@@ -88,7 +88,7 @@ def close(self):
8888

8989
def process(self, datasets):
9090
for dataset in datasets:
91-
tags = '%s,server=%s,node=%s' % (_key(dataset.name.lower()), _val(''), _val(''))
91+
tags = '%s,server=%s,node=%s' % (_key(dataset.name.lower()), args.server, args.node)
9292
if self.start_timestamp:
9393
timestamp = dataset.start_time * 1000000000
9494
else:

0 commit comments

Comments
 (0)