@@ -46,10 +46,10 @@ def start_patch(target: str):
4646 return p .start ()
4747
4848 # Local, temporary dummy modules only if truly missing
49- if importlib .util .find_spec ("confluent_kafka" ) is None : # pragma: no cover - environment dependent
49+ if importlib .util .find_spec ("confluent_kafka" ) is None :
5050 dummy_ck = types .ModuleType ("confluent_kafka" )
5151
52- class DummyProducer : # minimal interface
52+ class DummyProducer :
5353 def __init__ (self , * _ , ** __ ):
5454 pass
5555
@@ -58,18 +58,18 @@ def produce(self, *_, **kwargs):
5858 if cb :
5959 cb (None , None )
6060
61- def flush (self ): # noqa: D401 - simple stub
61+ def flush (self ):
6262 return None
6363
64- dummy_ck .Producer = DummyProducer # type: ignore[attr-defined]
64+ dummy_ck .Producer = DummyProducer
6565
6666 class DummyKafkaException (Exception ):
6767 pass
6868
69- dummy_ck .KafkaException = DummyKafkaException # type: ignore[attr-defined]
69+ dummy_ck .KafkaException = DummyKafkaException
7070 exit_stack .enter_context (patch .dict (sys .modules , {"confluent_kafka" : dummy_ck }))
7171
72- if importlib .util .find_spec ("psycopg2" ) is None : # pragma: no cover - environment dependent
72+ if importlib .util .find_spec ("psycopg2" ) is None :
7373 dummy_pg = types .ModuleType ("psycopg2" )
7474 exit_stack .enter_context (patch .dict (sys .modules , {"psycopg2" : dummy_pg }))
7575
@@ -94,11 +94,11 @@ def get(self):
9494 return {"Body" : MockS3ObjectBody ()}
9595
9696 class MockS3Bucket :
97- def Object (self , _key ): # noqa: D401 - simple proxy
97+ def Object (self , _key ):
9898 return MockS3Object ()
9999
100100 class MockS3Resource :
101- def Bucket (self , _name ): # noqa: D401 - simple proxy
101+ def Bucket (self , _name ):
102102 return MockS3Bucket ()
103103
104104 mock_session = start_patch ("boto3.Session" )
0 commit comments