Skip to content

Commit 2385d9a

Browse files
committed
codeql fix
1 parent eb51898 commit 2385d9a

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/saluki/main.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33

44

55
import logging
6-
from logging import FileHandler
76
from typing import Tuple
87

98
from saluki.consume import consume
@@ -123,7 +122,7 @@ def main():
123122
broker, topic = parse_kafka_uri(args.topic)
124123

125124
if args.log_file:
126-
logger.addHandler(FileHandler(args.log_file.name))
125+
logger.addHandler(logging.FileHandler(args.log_file.name))
127126

128127
if args.command == _LISTEN:
129128
listen(broker, topic, args.partition)
@@ -136,8 +135,6 @@ def main():
136135
args.offset,
137136
args.go_forwards,
138137
)
139-
elif args.command == _PRODUCE:
140-
raise NotImplementedError
141138

142139

143140
if __name__ == "__main__":

0 commit comments

Comments
 (0)