Home / ag2ai / faststream
AI Slop Code Risk Monitor

ag2ai/faststream

SlopCodeMonitor badge for ag2ai/faststream Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).
23.0 Elevated pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for ag2ai/faststream. SynthScan examined 163,120 lines of code across 2381 source files, recording 3454 pattern matches distributed across 16 syntactic categories. The legacy adjusted pattern signal is 23.0 (Elevated pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

23.0
Adjusted Signal
23.0
Raw Pattern Score
100%
Time Factor
—
Last Push
—
Stars
—
Language
163.1K
Lines of Code
2.4K
Files
3.5K
Pattern Hits
2026-10-31
Scan Date
0.03
HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 38.9/100 · MEDIUM

Can maintainers explain intent, assumptions, and trade-offs? 1595 finding(s).

Hallucinated Dependency & Supply Chain Risk 40.8/100 · MEDIUM

Are imports declared and package/API names verified? 1713 finding(s).

Agent Over-Engineering Ratio 45.2/100 · MEDIUM

Are wrappers, guards, and repeated structures necessary? 1690 finding(s).

PR Review Velocity Impact 69.1/100 · HIGH

Which changes need focused human review? 3454 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

Run additional scans to build a history of the legacy pattern signal. Score changes are not a measure of AI adoption or code quality.

No multi-scan history yet — run the scanner again to build trend data.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 1HIGH 73MEDIUM 3LOW 3377

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 3454 distinct pattern matches across 16 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Unused Imports1709 hits · 1675 pts
SeverityFileLineSnippetContext
LOWtests/tools.py2CODE
LOWtests/marks.py31CODE
LOWtests/marks.py44CODE
LOWtests/marks.py64CODE
LOWtests/marks.py77CODE
LOWtests/marks.py97CODE
LOWtests/marks.py110CODE
LOWtests/brokers/confluent/test_parser.py7CODE
LOWtests/brokers/confluent/test_parser.py9CODE
LOWtests/brokers/kafka/test_message.py1CODE
LOWtests/brokers/rabbit/specific/test_declare.py10CODE
LOWtests/brokers/rabbit/specific/test_declare.py12CODE
LOWtests/brokers/base/driver_annotations.py13CODE
LOWtests/brokers/base/future/fastapi.py1CODE
LOWtests/asyncapi/base/v2_6_0/__init__.py1CODE
LOWtests/asyncapi/base/v2_6_0/__init__.py1CODE
LOWtests/asyncapi/base/v3_0_0/__init__.py1CODE
LOWtests/asyncapi/base/v3_0_0/__init__.py1CODE
LOW…cs/confluent/publisher_object/test_publisher_object.py3CODE
LOWtests/docs/confluent/raw_publish/test_raw_publish.py3CODE
LOWtests/docs/redis/pub_sub/test_raw_publish.py3CODE
LOWtests/docs/redis/pub_sub/test_publisher_object.py3CODE
LOW…s/docs/kafka/publisher_object/test_publisher_object.py3CODE
LOWtests/docs/kafka/raw_publish/test_raw_publish.py3CODE
LOW…s/docs/getting_started/dependencies/basic/test_base.py1CODE
LOW…s/docs/getting_started/dependencies/basic/test_base.py4CODE
LOWtests/examples/kafka/test_example.py3CODE
LOWdocs/docs_src/confluent/security/sasl_gssapi.py1CODE
LOWdocs/docs_src/confluent/batch_consuming_pydantic/app.py1CODE
LOWdocs/docs_src/kafka/batch_consuming_pydantic/app.py1CODE
LOW…/docs_src/getting_started/routers/redis/delay_equal.py3CODE
LOW…/docs_src/getting_started/routers/redis/delay_equal.py3CODE
LOW…s/docs_src/getting_started/routers/mqtt/delay_equal.py3CODE
LOW…s/docs_src/getting_started/routers/mqtt/delay_equal.py3CODE
LOW…_src/getting_started/subscription/mqtt/dynamic_iter.py1CODE
LOWfaststream/security.py1CODE
LOWfaststream/security.py6CODE
LOWfaststream/__init__.py3CODE
LOWfaststream/__init__.py4CODE
LOWfaststream/__init__.py5CODE
LOWfaststream/__init__.py6CODE
LOWfaststream/__init__.py6CODE
LOWfaststream/__init__.py7CODE
LOWfaststream/__init__.py8CODE
LOWfaststream/__init__.py8CODE
LOWfaststream/__init__.py9CODE
LOWfaststream/__init__.py9CODE
LOWfaststream/__init__.py9CODE
LOWfaststream/__init__.py10CODE
LOWfaststream/__init__.py10CODE
LOWfaststream/__init__.py10CODE
LOWfaststream/__init__.py10CODE
LOWfaststream/__init__.py10CODE
LOWfaststream/__init__.py11CODE
LOWfaststream/__init__.py11CODE
LOWfaststream/__init__.py11CODE
LOWfaststream/__init__.py11CODE
LOWfaststream/__init__.py12CODE
LOWfaststream/types.py1CODE
LOWfaststream/types.py1CODE
1649 more matches not shown…
Hyper-Verbose Identifiers1335 hits · 1386 pts
SeverityFileLineSnippetContext
LOWtests/conftest.py15def pytest_keyboard_interrupt(CODE
LOWtests/conftest.py21def pytest_collection_modifyitems(items: list[pytest.Item]) -> None:CODE
LOWtests/mocks.py10def mock_pydantic_settings_env(CODE
LOWtests/brokers/test_install_hint.py28def test_missing_package_points_at_the_extra(broker: str, package: str) -> None:CODE
LOWtests/brokers/test_install_hint.py35def test_broken_package_keeps_its_own_error(broker: str, package: str) -> None:CODE
LOW⚡tests/brokers/test_response.py10def test_response_with_response_instance() -> None:CODE
LOW⚡tests/brokers/test_response.py16def test_add_headers_not_overrides() -> None:CODE
LOW⚡tests/brokers/test_response.py22def test_add_headers_overrides() -> None:CODE
LOWtests/brokers/test_stop.py62async def test_subscribers_stop_together() -> None:CODE
LOWtests/brokers/test_stop.py80async def test_failing_subscriber_does_not_prevent_others_from_stopping() -> None:CODE
LOWtests/brokers/confluent/test_parser.py118async def test_parse_reserved_headers(CODE
LOWtests/brokers/confluent/test_parser.py151async def test_parse_batch_reserved_headers(CODE
LOWtests/brokers/confluent/test_security.py14def patch_aio_consumer_and_producer() -> Generator[CODE
LOWtests/brokers/confluent/test_security.py28async def test_base_security_pass_ssl_context() -> None:CODE
LOWtests/brokers/confluent/test_connect.py16async def test_correct_config_merging(queue: str) -> None:CODE
LOWtests/brokers/confluent/test_connect.py51def test_correct_config_with_dict() -> None:CODE
LOWtests/brokers/confluent/test_raw_headers.py41def test_raw_headers_preserve_wire_values(record: MockConfluentMessage) -> None:CODE
LOWtests/brokers/confluent/test_raw_headers.py54def test_batch_raw_headers_preserve_wire_values(record: MockConfluentMessage) -> None:CODE
LOWtests/brokers/confluent/test_raw_headers.py69def test_missing_headers_are_empty(raw_message: Message | tuple[Message, ...]) -> None:CODE
LOWtests/brokers/confluent/test_option_surface.py10def test_every_level_takes_the_options_the_broker_takes() -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py105 def test_str_is_normalized_to_topic(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py112 def test_str_and_topic_are_mixed(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py119 def test_specification_uses_topic_names(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py152 def test_topic_keeps_settings(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py157 def test_topic_names_are_prefixed_once(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py162 def test_partition_names_are_prefixed_once(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py172 def test_keeps_declared_topics(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py180 def test_filters_out_not_declared_topics(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py185 def test_partitions_use_default_settings(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py190 def test_partitions_can_opt_out(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py197 def test_duplicate_names_collapse_to_the_last(self) -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py268def test_admin_skips_request_without_topics() -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py277def test_publisher_accepts_topic() -> None:CODE
LOW⚡tests/brokers/confluent/test_topic.py286async def test_consume_topic_object(queue: str, mock: MagicMock) -> None:CODE
LOWtests/brokers/confluent/test_topic.py54 def test_equality_follows_settings(self, other: object, equal: bool) -> None:CODE
LOWtests/brokers/confluent/test_topic.py60 def test_add_prefix_keeps_settings(self) -> None:CODE
LOWtests/brokers/confluent/test_topic.py86 def test_add_prefix_keeps_declare(self) -> None:CODE
LOWtests/brokers/confluent/test_topic.py92 def test_to_confluent_ignores_declare(self) -> None:CODE
LOWtests/brokers/confluent/test_topic.py214 def test_conflicting_settings_warn(self) -> None:CODE
LOWtests/brokers/confluent/test_topic.py223 def test_warning_points_at_the_caller(self) -> None:CODE
LOWtests/brokers/confluent/test_topic.py239 def test_no_warning_without_a_conflict(CODE
LOWtests/brokers/confluent/test_topic.py252def test_admin_creates_topics_with_their_settings() -> None:CODE
LOWtests/brokers/confluent/test_topic.py302async def test_topic_is_created_with_its_settings(queue: str) -> None:CODE
LOWtests/brokers/confluent/test_topic.py319async def test_not_declared_topic_is_not_created(queue: str) -> None:CODE
LOWtests/brokers/confluent/test_message.py35async def test_batch_nack_rewinds_every_partition() -> None:CODE
LOWtests/brokers/confluent/test_message.py53async def test_single_message_nack_rewinds_its_partition() -> None:CODE
LOWtests/brokers/confluent/test_test_reentrancy.py51async def _test_with_temp_subscriber() -> None:CODE
LOWtests/brokers/confluent/test_test_reentrancy.py71async def test_with_temp_subscriber() -> None:CODE
LOWtests/brokers/confluent/test_producer_headers.py31async def test_producer_publish_preserves_binary_and_null_headers() -> None:CODE
LOWtests/brokers/confluent/test_producer_headers.py59async def test_producer_publish_batch_preserves_binary_and_null_headers() -> None:CODE
LOWtests/brokers/confluent/test_producer_headers.py86async def test_native_producer_send_receives_header_sequences_as_lists() -> None:CODE
LOWtests/brokers/confluent/test_producer_headers.py112async def test_native_producer_send_batch_receives_header_sequences_as_lists() -> None:CODE
LOWtests/brokers/confluent/test_publish_command.py12 def test_kafka_response_class(self) -> None:CODE
LOWtests/brokers/confluent/test_lazy_logger_proxy.py12def test_proxy_drops_records_before_setup() -> None:CODE
LOWtests/brokers/confluent/test_lazy_logger_proxy.py31def test_proxy_forwards_after_setup() -> None:CODE
LOWtests/brokers/confluent/test_misconfigure.py18def test_max_workers_with_ack_policy(queue: str) -> None:CODE
LOWtests/brokers/confluent/test_misconfigure.py32def test_manual_ack_policy_without_group(queue: str) -> None:CODE
LOWtests/brokers/confluent/test_misconfigure.py53def test_use_only_confluent_router() -> None:CODE
LOWtests/brokers/confluent/test_misconfigure.py67def test_max_workers_ignored_by_batch(queue: str) -> None:CODE
LOW⚡tests/brokers/confluent/test_test_client.py385 async def test_broker_gets_patched_attrs_within_cm(self) -> None:CODE
1275 more matches not shown…
Cross-File Repetition65 hits · 325 pts
SeverityFileLineSnippetContext
HIGHtests/brokers/confluent/test_raw_headers.py0fixes https://github.com/ag2ai/faststream/issues/2214.STRING
HIGHtests/brokers/confluent/test_producer_headers.py0fixes https://github.com/ag2ai/faststream/issues/2214.STRING
HIGHtests/brokers/kafka/test_raw_headers.py0fixes https://github.com/ag2ai/faststream/issues/2214.STRING
HIGHtests/brokers/kafka/test_producer_headers.py0fixes https://github.com/ag2ai/faststream/issues/2214.STRING
HIGHtests/brokers/base/header.py0fixes https://github.com/ag2ai/faststream/issues/2214.STRING
HIGHtests/brokers/confluent/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/3056. an empty result publishes one empty message, exactly as a non-batSTRING
HIGHtests/brokers/redis/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/3056. an empty result publishes one empty message, exactly as a non-batSTRING
HIGHtests/brokers/kafka/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/3056. an empty result publishes one empty message, exactly as a non-batSTRING
HIGHtests/brokers/confluent/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/2513.STRING
HIGHtests/brokers/redis/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/2513.STRING
HIGHtests/brokers/nats/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/2513.STRING
HIGHtests/brokers/kafka/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/2513.STRING
HIGHtests/brokers/rabbit/test_test_client.py0fixes https://github.com/ag2ai/faststream/issues/2513.STRING
HIGH.agents/skills/testing-patterns/SKILL.md0fixes https://github.com/ag2ai/faststream/issues/2513.STRING
HIGHtests/brokers/kafka/test_rebalance_listener.py0fixes https://github.com/ag2ai/faststream/issues/3202.STRING
HIGHtests/brokers/kafka/test_config.py0fixes https://github.com/ag2ai/faststream/issues/3202.STRING
HIGHtests/brokers/kafka/test_client_rack.py0fixes https://github.com/ag2ai/faststream/issues/3202.STRING
HIGHfaststream/_internal/endpoint/publisher/fake.py0publisher interface implementation to use as rpc or reply to answer publisher.STRING
HIGHfaststream/confluent/publisher/fake.py0publisher interface implementation to use as rpc or reply to answer publisher.STRING
HIGHfaststream/redis/publisher/fake.py0publisher interface implementation to use as rpc or reply to answer publisher.STRING
HIGHfaststream/nats/publisher/fake.py0publisher interface implementation to use as rpc or reply to answer publisher.STRING
HIGHfaststream/kafka/publisher/fake.py0publisher interface implementation to use as rpc or reply to answer publisher.STRING
HIGHfaststream/rabbit/publisher/fake.py0publisher interface implementation to use as rpc or reply to answer publisher.STRING
HIGHfaststream/_internal/endpoint/publisher/fake.py0this method should be called in subscriber flow only.STRING
HIGHfaststream/confluent/publisher/usecase.py0this method should be called in subscriber flow only.STRING
HIGHfaststream/redis/publisher/usecase.py0this method should be called in subscriber flow only.STRING
HIGHfaststream/nats/publisher/usecase.py0this method should be called in subscriber flow only.STRING
HIGHfaststream/kafka/publisher/usecase.py0this method should be called in subscriber flow only.STRING
HIGHfaststream/rabbit/publisher/usecase.py0this method should be called in subscriber flow only.STRING
HIGHfaststream/confluent/broker/router.py0initialized rabbitrouter. args: prefix: string prefix to add to all subscribers queues. handlers: route object to includSTRING
HIGHfaststream/redis/broker/router.py0initialized rabbitrouter. args: prefix: string prefix to add to all subscribers queues. handlers: route object to includSTRING
HIGHfaststream/nats/broker/router.py0initialized rabbitrouter. args: prefix: string prefix to add to all subscribers queues. handlers: route object to includSTRING
HIGHfaststream/kafka/broker/router.py0initialized rabbitrouter. args: prefix: string prefix to add to all subscribers queues. handlers: route object to includSTRING
HIGHfaststream/rabbit/broker/router.py0initialized rabbitrouter. args: prefix: string prefix to add to all subscribers queues. handlers: route object to includSTRING
HIGHfaststream/confluent/broker/registrator.py0creates long-living and specification-documented publisher object. you can use it as a handler decorator (handler shouldSTRING
HIGHfaststream/kafka/broker/registrator.py0creates long-living and specification-documented publisher object. you can use it as a handler decorator (handler shouldSTRING
HIGHfaststream/kafka/fastapi/fastapi.py0creates long-living and specification-documented publisher object. you can use it as a handler decorator (handler shouldSTRING
HIGH…ation/asyncapi/v2_6_0/schema/bindings/redis/channel.py0asyncapi redis bindings. references: https://github.com/asyncapi/bindings/tree/master/redisSTRING
HIGH…ion/asyncapi/v2_6_0/schema/bindings/redis/operation.py0asyncapi redis bindings. references: https://github.com/asyncapi/bindings/tree/master/redisSTRING
HIGHfaststream/specification/schema/bindings/redis.py0asyncapi redis bindings. references: https://github.com/asyncapi/bindings/tree/master/redisSTRING
HIGH…cation/asyncapi/v2_6_0/schema/bindings/amqp/channel.py0asyncapi amqp bindings. references: https://github.com/asyncapi/bindings/tree/master/amqpSTRING
HIGH…tion/asyncapi/v2_6_0/schema/bindings/amqp/operation.py0asyncapi amqp bindings. references: https://github.com/asyncapi/bindings/tree/master/amqpSTRING
HIGH…tion/asyncapi/v3_0_0/schema/bindings/amqp/operation.py0asyncapi amqp bindings. references: https://github.com/asyncapi/bindings/tree/master/amqpSTRING
HIGH…ication/asyncapi/v2_6_0/schema/bindings/sqs/channel.py0asyncapi sqs bindings. references: https://github.com/asyncapi/bindings/tree/master/sqsSTRING
HIGH…ation/asyncapi/v2_6_0/schema/bindings/sqs/operation.py0asyncapi sqs bindings. references: https://github.com/asyncapi/bindings/tree/master/sqsSTRING
HIGHfaststream/specification/schema/bindings/sqs.py0asyncapi sqs bindings. references: https://github.com/asyncapi/bindings/tree/master/sqsSTRING
HIGH…cation/asyncapi/v2_6_0/schema/bindings/nats/channel.py0asyncapi nats bindings. references: https://github.com/asyncapi/bindings/tree/master/natsSTRING
HIGH…tion/asyncapi/v2_6_0/schema/bindings/nats/operation.py0asyncapi nats bindings. references: https://github.com/asyncapi/bindings/tree/master/natsSTRING
HIGHfaststream/specification/schema/bindings/nats.py0asyncapi nats bindings. references: https://github.com/asyncapi/bindings/tree/master/natsSTRING
HIGH…ation/asyncapi/v2_6_0/schema/bindings/kafka/channel.py0asyncapi kafka bindings. references: https://github.com/asyncapi/bindings/tree/master/kafkaSTRING
HIGH…ion/asyncapi/v2_6_0/schema/bindings/kafka/operation.py0asyncapi kafka bindings. references: https://github.com/asyncapi/bindings/tree/master/kafkaSTRING
HIGHfaststream/specification/schema/bindings/kafka.py0asyncapi kafka bindings. references: https://github.com/asyncapi/bindings/tree/master/kafkaSTRING
HIGH…cation/asyncapi/v2_6_0/schema/bindings/mqtt/channel.py0asyncapi mqtt bindings. references: https://github.com/asyncapi/bindings/tree/master/mqttSTRING
HIGH…tion/asyncapi/v2_6_0/schema/bindings/mqtt/operation.py0asyncapi mqtt bindings. references: https://github.com/asyncapi/bindings/tree/master/mqttSTRING
HIGHfaststream/specification/schema/bindings/mqtt.py0asyncapi mqtt bindings. references: https://github.com/asyncapi/bindings/tree/master/mqttSTRING
HIGH…cation/asyncapi/v2_6_0/schema/bindings/main/channel.py0a class to represent channel bindings. attributes: amqp : amqp channel binding (optional) kafka : kafka channel binding STRING
HIGH…cation/asyncapi/v3_0_0/schema/bindings/main/channel.py0a class to represent channel bindings. attributes: amqp : amqp channel binding (optional) kafka : kafka channel binding STRING
HIGHfaststream/specification/schema/bindings/main.py0a class to represent channel bindings. attributes: amqp : amqp channel binding (optional) kafka : kafka channel binding STRING
HIGH…tion/asyncapi/v2_6_0/schema/bindings/main/operation.py0a class to represent an operation binding. attributes: amqp : amqp operation binding (optional) kafka : kafka operation STRING
HIGH…tion/asyncapi/v3_0_0/schema/bindings/main/operation.py0a class to represent an operation binding. attributes: amqp : amqp operation binding (optional) kafka : kafka operation STRING
5 more matches not shown…
AI Structural Patterns209 hits · 157 pts
SeverityFileLineSnippetContext
LOWfaststream/app.py45CODE
LOWfaststream/_internal/application.py139CODE
LOWfaststream/_internal/cli/main.py94CODE
LOWfaststream/_internal/kafka/calls.py25CODE
LOWfaststream/_internal/kafka/calls.py66CODE
LOWfaststream/_internal/kafka/calls.py107CODE
LOWfaststream/_internal/kafka/calls.py148CODE
LOWfaststream/_internal/fastapi/router.py105CODE
LOWfaststream/_internal/fastapi/router.py198CODE
LOWfaststream/_internal/fastapi/router.py486CODE
LOWfaststream/_internal/fastapi/router.py416CODE
LOWfaststream/asgi/app.py92CODE
LOWfaststream/asgi/factories/asyncapi/route.py21CODE
LOWfaststream/asgi/factories/asyncapi/docs.py19CODE
LOWfaststream/confluent/response.py71CODE
LOWfaststream/confluent/testing.py356CODE
LOWfaststream/confluent/broker/router.py35CODE
LOWfaststream/confluent/broker/router.py98CODE
LOWfaststream/confluent/broker/router.py326CODE
LOWfaststream/confluent/broker/broker.py76CODE
LOWfaststream/confluent/broker/registrator.py49CODE
LOWfaststream/confluent/broker/registrator.py93CODE
LOWfaststream/confluent/broker/registrator.py137CODE
LOWfaststream/confluent/broker/registrator.py181CODE
LOWfaststream/confluent/broker/registrator.py229CODE
LOWfaststream/confluent/broker/registrator.py464CODE
LOWfaststream/confluent/broker/registrator.py484CODE
LOWfaststream/confluent/broker/registrator.py504CODE
LOWfaststream/confluent/broker/registrator.py527CODE
LOWfaststream/confluent/publisher/usecase.py118CODE
LOWfaststream/confluent/publisher/usecase.py133CODE
LOWfaststream/confluent/publisher/usecase.py148CODE
LOWfaststream/confluent/publisher/usecase.py163CODE
LOWfaststream/confluent/publisher/usecase.py255CODE
LOWfaststream/confluent/fastapi/fastapi.py68CODE
LOWfaststream/confluent/fastapi/fastapi.py406CODE
LOWfaststream/confluent/fastapi/fastapi.py456CODE
LOWfaststream/confluent/fastapi/fastapi.py506CODE
LOWfaststream/confluent/fastapi/fastapi.py554CODE
LOWfaststream/confluent/fastapi/fastapi.py608CODE
LOWfaststream/confluent/fastapi/fastapi.py916CODE
LOWfaststream/confluent/fastapi/fastapi.py934CODE
LOWfaststream/confluent/fastapi/fastapi.py952CODE
LOWfaststream/confluent/fastapi/fastapi.py970CODE
LOWfaststream/confluent/helpers/config.py309CODE
LOWfaststream/confluent/helpers/client.py227CODE
LOWfaststream/redis/response.py58CODE
LOWfaststream/redis/broker/router.py36CODE
LOWfaststream/redis/broker/router.py94CODE
LOWfaststream/redis/broker/router.py178CODE
LOWfaststream/redis/broker/broker.py199CODE
LOWfaststream/redis/broker/broker.py214CODE
LOWfaststream/redis/broker/broker.py229CODE
LOWfaststream/redis/broker/cluster_broker.py115CODE
LOWfaststream/redis/broker/registrator.py49CODE
LOWfaststream/redis/broker/registrator.py72CODE
LOWfaststream/redis/broker/registrator.py95CODE
LOWfaststream/redis/broker/registrator.py118CODE
LOWfaststream/redis/broker/registrator.py141CODE
LOWfaststream/redis/broker/registrator.py164CODE
149 more matches not shown…
Excessive Try-Catch Wrapping39 hits · 40 pts
SeverityFileLineSnippetContext
LOWtests/brokers/base/middlewares.py374 except Exception as e:CODE
LOWtests/cli/test_asyncapi_docs.py221 except Exception as e:STRING
LOWtests/examples/nats/test_e07_object_storage.py19 except Exception:CODE
LOWdocs/create_api_docs.py74 except Exception:CODE
LOWdocs/update_releases.py35 except Exception as e:CODE
LOWdocs/docs/en/getting-started/acknowledgement.md124 except Exception:CODE
LOWdocs/docs/en/getting-started/middlewares/index.md342 except Exception:CODE
LOW⚡…/docs/en/getting-started/observability/healthchecks.md70 except Exception:CODE
LOW⚡…/docs/en/getting-started/observability/healthchecks.md76 except Exception:CODE
LOW⚡…/docs/en/getting-started/observability/healthchecks.md82 except Exception:CODE
LOWdocs/docs_src/redis/stream/claiming_manual_ack.py23 except Exception as e:CODE
LOWfaststream/_internal/broker/broker.py138 except Exception as e:CODE
LOWfaststream/_internal/cli/main.py302 except Exception as e:CODE
LOWfaststream/_internal/cli/main.py322 except Exception as e:CODE
LOWfaststream/_internal/testing/broker.py88 except Exception: # pragma: no coverCODE
LOWfaststream/_internal/endpoint/subscriber/call_item.py156 except Exception as e:CODE
LOWfaststream/_internal/endpoint/subscriber/usecase.py360 except Exception: # nosec B110 # ruff: ignore[try-except-pass]CODE
LOWfaststream/_internal/endpoint/subscriber/usecase.py399 except Exception as e:CODE
LOWfaststream/_internal/fastapi/router.py470 except Exception as e:CODE
LOWfaststream/asgi/handlers.py67 except Exception:CODE
LOWfaststream/asgi/factories/asyncapi/try_it_out.py133 except Exception as e:CODE
LOWfaststream/asgi/factories/asyncapi/try_it_out.py157 except Exception as e:CODE
LOWfaststream/confluent/helpers/client.py207 except Exception:CODE
LOWfaststream/confluent/helpers/client.py389 except Exception as e:CODE
LOWfaststream/confluent/helpers/admin.py65 except Exception as e:CODE
LOWfaststream/redis/parser/binary.py96 except Exception:CODE
LOWfaststream/redis/parser/binary.py102 except Exception:CODE
LOWfaststream/redis/parser/parsers.py225 except Exception:CODE
LOW…tstream/redis/subscriber/usecases/stream_subscriber.py140 except Exception as e:CODE
LOWfaststream/redis/subscriber/usecases/basic.py100 except Exception as e: # ruff: ignore[try-except-in-loop]CODE
LOWfaststream/opentelemetry/middleware.py255 except Exception as e:CODE
LOWfaststream/opentelemetry/middleware.py326 except Exception as e:CODE
LOWfaststream/middlewares/exception.py158 except Exception as exc:CODE
LOWfaststream/middlewares/acknowledgement/middleware.py130 except Exception as er:CODE
LOWfaststream/kafka/broker/broker.py802 except Exception:CODE
LOWfaststream/kafka/helpers/admin.py66 except Exception as e:CODE
LOWfaststream/prometheus/middleware.py153 except Exception as e:CODE
LOWfaststream/prometheus/middleware.py219 except Exception as e:CODE
LOWfaststream/mqtt/broker/broker.py265 except Exception:CODE
Modern Structural Boilerplate38 hits · 38 pts
SeverityFileLineSnippetContext
LOW…cs/confluent/publisher_object/test_publisher_object.py7__all__ = ["test_prepared_publish"]CODE
LOWtests/docs/confluent/raw_publish/test_raw_publish.py7__all__ = ["test_raw_publish"]CODE
LOW…s/docs/kafka/publisher_object/test_publisher_object.py7__all__ = ["test_prepared_publish"]CODE
LOWtests/docs/kafka/raw_publish/test_raw_publish.py7__all__ = ["test_raw_publish"]CODE
LOWdocs/docs.py106def update_release_notes() -> None:CODE
LOW…etting_started/context/confluent/driver_annotations.py27async def set_storage(context: ContextRepo) -> None:CODE
LOW…rc/getting_started/context/redis/driver_annotations.py27async def set_storage(context: ContextRepo) -> None:CODE
LOW…src/getting_started/context/nats/driver_annotations.py27async def set_storage(context: ContextRepo) -> None:CODE
LOW…rc/getting_started/context/kafka/driver_annotations.py27async def set_storage(context: ContextRepo) -> None:CODE
LOW…c/getting_started/context/rabbit/driver_annotations.py27async def set_storage(context: ContextRepo) -> None:CODE
LOW…src/getting_started/context/mqtt/driver_annotations.py28async def set_storage(context: ContextRepo) -> None:CODE
LOWfaststream/types.py20__all__ = [CODE
LOWfaststream/_internal/application.py115 def set_broker(self, broker: "BrokerUsecase[Any, Any, Any]") -> None:CODE
LOWfaststream/_internal/broker/broker.py92 def _update_fd_config(self, config: "FastDependsConfig") -> None:CODE
LOWfaststream/_internal/broker/broker.py106 def _setup_logger(self) -> None:CODE
LOWfaststream/_internal/context/composition.py34 def set_global(self, key: str, v: Any) -> None:CODE
LOWfaststream/_internal/context/repository.py32 def set_global(self, key: str, v: Any) -> None:CODE
LOWfaststream/_internal/logger/params_storage.py32 def set_level(self, level: int) -> None: ...CODE
LOWfaststream/_internal/logger/params_storage.py45 def set_level(self, level: int) -> None:CODE
LOWfaststream/_internal/logger/params_storage.py61 def set_level(self, level: int) -> None:CODE
LOWfaststream/_internal/logger/params_storage.py88 def set_level(self, level: int) -> None:CODE
LOWfaststream/_internal/logger/state.py60 def set_level(self, level: int) -> None:CODE
LOWfaststream/_internal/logger/state.py78 def _setup(self, context: "ContextRepo", /) -> None:CODE
LOWfaststream/_internal/cli/utils/logs.py82def set_log_level(level: int, app: "Application") -> None:CODE
LOWfaststream/_internal/cli/utils/logs.py145def set_log_config(file: Path) -> None:CODE
LOWfaststream/_internal/endpoint/call_wrapper.py137 def set_test(self) -> None:CODE
LOWfaststream/_internal/fastapi/config.py13 def set_application(self, app: "FastAPI") -> None:CODE
LOWfaststream/asgi/handlers.py79 def update_fd_config(self, config: FastDependsConfig) -> None:CODE
LOWfaststream/asgi/handlers.py85 def set_logger(self, logger: "LoggerProto | None") -> None:CODE
LOWfaststream/confluent/parser.py36 def _setup(self, consumer: "ConsumerProtocol") -> None:CODE
LOWfaststream/confluent/broker/logging.py27 def set_level(self, level: int) -> None:CODE
LOWfaststream/redis/broker/logging.py23 def set_level(self, level: int) -> None:CODE
LOWfaststream/redis/parser/parsers.py159 def _setup(self, consumer: ConsumerProtocol, group: str | None) -> None:CODE
LOWfaststream/message/message.py69 def set_decoder(self, decoder: "AsyncCallable") -> None:CODE
LOWfaststream/nats/broker/logging.py29 def set_level(self, level: int) -> None:CODE
LOWfaststream/kafka/parser.py40 def _setup(self, consumer: ConsumerProtocol) -> None:CODE
LOWfaststream/kafka/broker/logging.py27 def set_level(self, level: int) -> None:CODE
LOWfaststream/mqtt/broker/logging.py26 def set_level(self, level: int) -> None:CODE
Deep Nesting25 hits · 24 pts
SeverityFileLineSnippetContext
LOWtests/docs/test_snippets_are_tested.py57CODE
LOWdocs/check_site.py45CODE
LOWfaststream/_internal/cli/docs.py193CODE
LOWfaststream/_internal/cli/main.py94CODE
LOWfaststream/_internal/cli/utils/parser.py19CODE
LOW…ststream/_internal/endpoint/publisher/specification.py43CODE
LOWfaststream/_internal/fastapi/get_dependant.py161CODE
LOWfaststream/asgi/handlers.py43CODE
LOWfaststream/confluent/testing.py436CODE
LOWfaststream/redis/testing.py137CODE
LOWfaststream/redis/broker/broker.py362CODE
LOWfaststream/redis/publisher/producer.py249CODE
LOW…tstream/redis/subscriber/usecases/stream_subscriber.py307CODE
LOWfaststream/redis/subscriber/usecases/basic.py93CODE
LOWfaststream/middlewares/exception.py165CODE
LOWfaststream/middlewares/acknowledgement/middleware.py83CODE
LOWfaststream/specification/asyncapi/utils.py61CODE
LOWfaststream/specification/asyncapi/v2_6_0/generate.py261CODE
LOWfaststream/specification/asyncapi/v3_0_0/generate.py325CODE
LOWfaststream/nats/testing.py236CODE
LOWfaststream/nats/broker/broker.py704CODE
LOWfaststream/nats/subscriber/factory.py255CODE
LOW…/nats/subscriber/usecases/object_storage_subscriber.py169CODE
LOWfaststream/kafka/testing.py399CODE
LOWfaststream/rabbit/testing.py392CODE
Cross-Language Confusion3 hits · 22 pts
SeverityFileLineSnippetContext
HIGH⚡faststream/_internal/basic_types.py76 SendableMessage: TypeAlias = Struct | BaseModel | BaseSendableMessage # type: ignore[possibly-undefined]CODE
HIGH⚡faststream/_internal/basic_types.py78 SendableMessage: TypeAlias = BaseModel | BaseSendableMessage # type: ignore[no-redef,misc,possibly-undefined]CODE
HIGH⚡faststream/_internal/basic_types.py80 SendableMessage: TypeAlias = Struct | BaseSendableMessage # type: ignore[no-redef,misc,possibly-undefined]CODE
Empty Error Handlers4 hits · 20 pts
SeverityFileLineSnippetContext
HIGHfaststream/_internal/context/composition.py83except ContextError: # ruff: ignore[try-except-in-loop]CODE
HIGHfaststream/_internal/endpoint/subscriber/usecase.py360except Exception: # nosec B110 # ruff: ignore[try-except-pass]CODE
HIGHfaststream/redis/broker/broker.py377except ConnectionError:CODE
HIGHbenchmarks/kafka_cases/test_aiokafka.py71except asyncio.CancelledError:CODE
Structural Annotation Overuse12 hits · 18 pts
SeverityFileLineSnippetContext
LOWdocs/docs/en/confluent/Publisher/using_a_key.md21### Step 1: Define the PublisherCOMMENT
LOWdocs/docs/en/confluent/Publisher/using_a_key.md29### Step 2: Pass the KeyCOMMENT
LOWdocs/docs/en/confluent/Subscriber/batch_subscriber.md19### Step 1: Define Your SubscriberCOMMENT
LOWdocs/docs/en/confluent/Subscriber/batch_subscriber.md27### Step 2: Implement Your Consuming FunctionCOMMENT
LOWdocs/docs/en/redis/streams/batch.md19### Step 1: Define Your SubscriberCOMMENT
LOWdocs/docs/en/redis/streams/batch.md27### Step 2: Implement Your Consuming FunctionCOMMENT
LOWdocs/docs/en/redis/list/batch.md19### Step 1: Define Your SubscriberCOMMENT
LOWdocs/docs/en/redis/list/batch.md27### Step 2: Implement Your Consuming FunctionCOMMENT
LOWdocs/docs/en/kafka/Publisher/using_a_key.md21### Step 1: Define the PublisherCOMMENT
LOWdocs/docs/en/kafka/Publisher/using_a_key.md29### Step 2: Pass the KeyCOMMENT
LOWdocs/docs/en/kafka/Subscriber/batch_subscriber.md19### Step 1: Define Your SubscriberCOMMENT
LOWdocs/docs/en/kafka/Subscriber/batch_subscriber.md27### Step 2: Implement Your Consuming FunctionCOMMENT
Hallucination Indicators1 hit · 15 pts
SeverityFileLineSnippetContext
CRITICAL⚡tests/brokers/redis/cluster/test_cluster_more_unit.py89 nodes = broker.config.broker_config.connection._options.get("startup_nodes", [])CODE
Over-Commented Block7 hits · 7 pts
SeverityFileLineSnippetContext
LOWpyproject.toml521| ^faststream\._internal\.broker\.broker:BrokerUsecase$COMMENT
LOWdocs/docs/.meta.yml1# 0.5 - APICOMMENT
LOWdocs/docs/en/getting-started/contributing/.meta.yml1# 0.5 - APICOMMENT
LOWdocs/docs/en/javascripts/context7-widget.js1// Material for MkDocs treats a keystroke as a global shortcut (s, f and /COMMENT
LOWdocs/docs/en/api/.meta.yml1# 0.5 - APICOMMENT
LOWfaststream/_internal/utils/nuid.py1# Copyright 2016-2018 The NATS AuthorsCOMMENT
LOW.github/workflows/pr_codeql.yaml1# For most projects, this workflow file will not need changing; you simply needCOMMENT
Self-Referential Comments2 hits · 6 pts
SeverityFileLineSnippetContext
MEDIUMtests/brokers/redis/test_autoclaim.py248 # Create a pending message first (before starting subscriber)COMMENT
MEDIUMtests/brokers/nats/test_request_cleanup.py74 # Creating the stream first includes the shared JetStream reply mux.COMMENT
Docstring Block Structure1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHfaststream/_internal/context/repository.py144Resolve the context of an argument. Args: argument: A string representing the argument. ReSTRING
Redundant / Tautological Comments3 hits · 4 pts
SeverityFileLineSnippetContext
LOWdocs/expand_markdown.py27 # Check if lines_spec is empty (indicating all lines should be read)COMMENT
LOWdocs/expand_markdown.py78 # Check if the line does not contain the "{!>" patternCOMMENT
LOWfaststream/_internal/logger/logging.py87 # Check if a StreamHandler for sys.stdout already exists in the logger.COMMENT
Modern AI Meta-Vocabulary1 hit · 2 pts
SeverityFileLineSnippetContext
MEDIUMADOPTERS.md101| [EggAI](https://github.com/eggai-tech) | agentic workforce automation | [EggAI](https://github.com/eggai-tech/EggAI) |CODE