Skip to content

Commit

Permalink
DPNLPF-1959: remove rudimentary publisher thread
Browse files Browse the repository at this point in the history
  • Loading branch information
SyrexMinus committed Oct 18, 2023
1 parent 0a7edd4 commit cedfbbb
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions smart_kit/start_points/main_loop_kafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,9 +56,6 @@ def __init__(self, *args, **kwargs):
self.loop = asyncio.get_event_loop()
self.health_check_server_future = None
super().__init__(*args, **kwargs)
# We have many async loops for messages processing in main thread
# And 1 thread for independent consecutive Kafka reading
self.kafka_executor_pool = concurrent.futures.ThreadPoolExecutor(max_workers=1)
self._timers = dict() # stores aio timers for callbacks
self.template_settings = self.settings["template_settings"]
self.profiling_settings = self.template_settings.get("profiling", {})
Expand Down

0 comments on commit cedfbbb

Please sign in to comment.