feat: Add Kafka as a transport #1607
bigxin0124Annotations
23 errors and 9 notices
|
Lint Code Base
Process completed with exit code 1.
|
|
Lint Code Base
Error: Unexpected HTTP response: 429
|
|
Lint Code Base
Process completed with exit code 1.
|
|
Lint Code Base:
tests/client/test_kafka_client.py#L0
Would reformat
|
|
Lint Code Base:
test_simple_kafka.py#L0
Would reformat
|
|
Lint Code Base:
test_handler.py#L0
Would reformat
|
|
Lint Code Base:
src/a2a/types.py#L0
Would reformat
|
|
|
|
|
|
Lint Code Base:
src/a2a/server/apps/kafka/kafka_app.py#L0
Would reformat
|
|
|
|
Lint Code Base:
src/a2a/client/transports/kafka.py#L0
Would reformat
|
|
Lint Code Base:
src/a2a/client/client_factory.py#L0
Would reformat
|
|
Ruff (Q000):
src/a2a/client/transports/kafka.py#L43
src/a2a/client/transports/kafka.py:43:30: Q000 Double quotes found but single quotes preferred
|
|
Ruff (Q000):
src/a2a/client/transports/kafka.py#L42
src/a2a/client/transports/kafka.py:42:46: Q000 Double quotes found but single quotes preferred
|
|
Ruff (UP006):
src/a2a/client/transports/kafka.py#L42
src/a2a/client/transports/kafka.py:42:34: UP006 Use `list` instead of `List` for type annotation
|
|
Ruff (PLR0913):
src/a2a/client/transports/kafka.py#L39
src/a2a/client/transports/kafka.py:39:9: PLR0913 Too many arguments in function definition (6 > 5)
|
|
Ruff (UP035):
src/a2a/client/transports/kafka.py#L8
src/a2a/client/transports/kafka.py:8:1: UP035 `typing.List` is deprecated, use `list` instead
|
|
Ruff (UP035):
src/a2a/client/transports/kafka.py#L8
src/a2a/client/transports/kafka.py:8:1: UP035 `typing.Dict` is deprecated, use `dict` instead
|
|
Ruff (I001):
src/a2a/client/transports/kafka.py#L3
src/a2a/client/transports/kafka.py:3:1: I001 Import block is un-sorted or un-formatted
|
|
Ruff (W293):
src/a2a/client/client_factory.py#L129
src/a2a/client/client_factory.py:129:1: W293 Blank line contains whitespace
|
|
Ruff (SLF001):
src/a2a/client/client_factory.py#L128
src/a2a/client/client_factory.py:128:9: SLF001 Private member accessed: `_auto_start`
|
|
Ruff (W293):
src/a2a/client/client_factory.py#L126
src/a2a/client/client_factory.py:126:1: W293 Blank line contains whitespace
|
|
Lint Code Base
repository contains 26 duplications.
8 duplications were part of this PR and were annotated
|
|
Copy/pasted code:
src/a2a/client/transports/kafka.py#L343
see src/a2a/client/transports/kafka.py (554-569)
|
|
Copy/pasted code:
src/a2a/client/transports/kafka.py#L554
see src/a2a/client/transports/kafka.py (343-358)
|
|
Copy/pasted code:
src/a2a/client/transports/kafka.py#L447
see src/a2a/client/transports/kafka.py (496-505)
|
|
Copy/pasted code:
src/a2a/client/transports/kafka.py#L496
see src/a2a/client/transports/kafka.py (447-456)
|
|
Copy/pasted code:
src/a2a/client/transports/kafka.py#L369
see src/a2a/client/transports/kafka.py (395-410)
|
|
Copy/pasted code:
src/a2a/client/transports/kafka.py#L395
see src/a2a/client/transports/kafka.py (369-384)
|
|
Copy/pasted code:
src/a2a/server/request_handlers/kafka_handler.py#L226
see src/a2a/server/request_handlers/kafka_handler.py (245-260)
|
|
Copy/pasted code:
src/a2a/server/request_handlers/kafka_handler.py#L245
see src/a2a/server/request_handlers/kafka_handler.py (226-241)
|