diff --git a/logprep/processor/domain_resolver/processor.py b/logprep/processor/domain_resolver/processor.py index bfb4415ea..3b5655651 100644 --- a/logprep/processor/domain_resolver/processor.py +++ b/logprep/processor/domain_resolver/processor.py @@ -212,7 +212,6 @@ def _add_resolve_infos_to_event(self, event, rule, resolved_ip): def _resolve_ip(self, domain, hash_string=None): try: - print(socket.gethostbyname) result = self._thread_pool.apply_async(socket.gethostbyname, (domain,)) resolved_ip = result.get(timeout=self._config.timeout) return resolved_ip diff --git a/tests/unit/connector/test_http_input.py b/tests/unit/connector/test_http_input.py index 09f4aac9c..9f6e17477 100644 --- a/tests/unit/connector/test_http_input.py +++ b/tests/unit/connector/test_http_input.py @@ -55,7 +55,7 @@ def create_credentials(tmp_path): class TestHttpConnector(BaseInputTestCase): def setup_method(self): - ThreadingHTTPServer.start = mock.MagicMock() + # ThreadingHTTPServer.start = mock.MagicMock() HttpInput.messages = ThrottlingQueue( ctx=multiprocessing.get_context(), maxsize=self.CONFIG.get("message_backlog_size") ) @@ -94,7 +94,7 @@ def teardown_method(self): while not self.object.messages.empty(): self.object.messages.get(timeout=0.001) self.object.shut_down() - ThreadingHTTPServer.start = original_thread_start + # ThreadingHTTPServer.start = original_thread_start def test_create_connector(self): assert isinstance(self.object, HttpInput)