2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-08-25 08:06:46 +00:00

Fix issue with non-systemd startup

This commit is contained in:
Jarrod Johnson
2026-08-21 07:15:52 -04:00
parent 8a2d5016f3
commit f5d7c271b5
+2 -1
View File
@@ -376,6 +376,7 @@ async def asyncrun(args):
webservice = httpapi.HttpApi(http_bind_host, http_bind_port, http_bind_group, http_bind_perms)
webservice.start()
notifysock = os.environ.get('NOTIFY_SOCKET', None)
watchdogsecs = 200
if notifysock:
watchdogsecs = int(os.environ.get('WATCHDOG_USEC', '0')) / 1000000
if not watchdogsecs:
@@ -446,4 +447,4 @@ def _get_connector_config(session):
return (host, port, group, perms)
def _get_logdirectory():
return conf.get_option('globals', 'logdirectory')
return conf.get_option('globals', 'logdirectory')