summaryrefslogtreecommitdiffstats
path: root/collectors/python.d.plugin/python.d.plugin.in
diff options
context:
space:
mode:
Diffstat (limited to 'collectors/python.d.plugin/python.d.plugin.in')
-rw-r--r--collectors/python.d.plugin/python.d.plugin.in10
1 files changed, 8 insertions, 2 deletions
diff --git a/collectors/python.d.plugin/python.d.plugin.in b/collectors/python.d.plugin/python.d.plugin.in
index 6521fed9..240c44e0 100644
--- a/collectors/python.d.plugin/python.d.plugin.in
+++ b/collectors/python.d.plugin/python.d.plugin.in
@@ -14,7 +14,7 @@ import sys
import threading
from re import sub
-from sys import version_info, argv
+from sys import version_info, argv, stdout
from time import sleep
GC_RUN = True
@@ -40,13 +40,15 @@ sys.path.append(PYTHON_MODULES_DIR)
from bases.loaders import ModuleAndConfigLoader # noqa: E402
from bases.loggers import PythonDLogger # noqa: E402
-from bases.collection import setdefault_values, run_and_exit # noqa: E402
+from bases.collection import setdefault_values, run_and_exit, safe_print # noqa: E402
try:
from collections import OrderedDict
except ImportError:
from third_party.ordereddict import OrderedDict
+IS_ATTY = stdout.isatty()
+
BASE_CONFIG = {'update_every': os.getenv('NETDATA_UPDATE_EVERY', 1),
'priority': 60000,
'autodetection_retry': 0,
@@ -394,6 +396,10 @@ class Plugin(object):
v = gc.collect()
Logger.debug("GC full collection run result: {0}".format(v))
+ # for exiting on SIGPIPE
+ if not IS_ATTY:
+ safe_print('\n')
+
def cleanup(self):
for job in self.dead_jobs:
self.delete_job(job)