async def kafka_read_ping(self):
await asyncio.gather(self.kafka_read(), self.kafka_ping())
async def kafka_read_ping(self):
await asyncio.gather(self.kafka_read(), self.kafka_ping())
self.ns = ns.NsLcm(self.msg, self.lcm_tasks, self.main_config)
# TODO: modify the rest of classes to use the LcmCfg object instead of dicts
self.ns = ns.NsLcm(self.msg, self.lcm_tasks, self.main_config)
# TODO: modify the rest of classes to use the LcmCfg object instead of dicts
except (LcmException, getopt.GetoptError) as e:
print(str(e), file=sys.stderr)
# usage()
except (LcmException, getopt.GetoptError) as e:
print(str(e), file=sys.stderr)
# usage()