Public scan — anyone with this URL can view this analysis. Sign up to track your own repos privately, run scheduled re-scans, and get AI fix prompts via your dashboard.
233 of your 445 findings came from Repobility's proprietary detections. ✓ Repobility tags below mark them.
Upstream (GitHub) caused delay on this scan — not Repobility.
  • GitHub API rate-limited (HTTP 403) — preflight skipped, fell back to direct git clone.
  • Clone from GitHub took 113.83s for a 215.5 MB repo slow.
  • Repobility's analysis ran in 11.69s after the clone landed.

pathwaycom/pathway

https://github.com/pathwaycom/pathway · scanned 2026-06-05 09:09 UTC (5 days, 17 hours ago) · 10 languages

977 raw signals (431 security + 546 graph) 11/13 scanners ran 91st percentile · Python · large (100-500K LoC) System graph score 58 (higher by 30)

UNIFIED Repobility · multi-layer engine · AI coders

Complete repo analysis

Last scanned 5 days, 17 hours ago · v2 · 332 actionable findings from 2 signal sources. 369 repeated signals grouped for readability. Security checks, system graph analysis, and verified AI-agent feedback are merged into one review queue.

JSON
Score breakdown â 2026-05-18-v5
Component Sub-score Weight Contribution
structure_score 85.0 0.15 12.75
security_score 100.0 0.25 25.00
testing_score 93.0 0.20 18.60
documentation_score 88.0 0.15 13.20
practices_score 77.0 0.15 11.55
code_quality 70.0 0.10 7.00
Overall 1.00 88.1
security_score may be inflated — optional security scanners were skipped on this fast scan
Severity distribution — click a segment to filter
Active filters: excluding tests × Reset all
Scan summary Quality grade A- (88/100). Dimensions: security 100, maintainability 85. 431 findings (86 security). 291,912 lines analyzed.

Showing 228 of 332 actionable findings. 701 raw detector signals were grouped into reader-sized issues. Click TP / FP to vote on a finding's accuracy — votes adjust the confidence weighting and improve detection across the platform.

critical Security checks quality Quality conf 1.00 ✓ Repobility [MINED030] Python Pickle Loads: pickle.loads() can execute arbitrary code via __reduce__.
Review and fix per the pattern semantics. See CWE-502 / for context.
python/pathway/stdlib/ml/hmm.py:200
critical Security checks quality Quality conf 1.00 ✓ Repobility [MINED030] Python Pickle Loads: pickle.loads() can execute arbitrary code via __reduce__.
Review and fix per the pattern semantics. See CWE-502 / for context.
examples/projects/twitter/services/pathway-app/app/geocoding.py:69
high Security checks quality Quality conf 1.00 ✓ Repobility 8 occurrences [MINED107] Missing import: `operator` used but not imported: The file uses `operator.something(...)` but never imports `operator`. This raises NameError at runtime the first time the line executes.
Add `import operator` at the top of the file.
8 files, 8 locations
python/pathway/internals/graph_runner/__init__.py:193
python/pathway/internals/graph_runner/operator_handler.py:109
python/pathway/internals/graph_runner/row_transformer_operator_handler.py:38
python/pathway/internals/graph_runner/storage_graph.py:233
python/pathway/internals/row_transformer_table.py:60
python/pathway/internals/type_interpreter.py:152
python/pathway/io/gdrive/__init__.py:174
python/pathway/stdlib/utils/bucketing.py:9
critical Security checks quality Quality conf 1.00 [SEC081] Python: pickle.loads / marshal.loads on untrusted data: pickle.load(s) and marshal.load(s) execute arbitrary code on untrusted input. Ported from dlint DUO103 / DUO120 (BSD-3).
Use json, msgpack, or protobuf for untrusted data. If pickle is required, sign the payload with HMAC.
python/pathway/stdlib/ml/hmm.py:200
critical Security checks quality Quality conf 1.00 [SEC081] Python: pickle.loads / marshal.loads on untrusted data: pickle.load(s) and marshal.load(s) execute arbitrary code on untrusted input. Ported from dlint DUO103 / DUO120 (BSD-3).
Use json, msgpack, or protobuf for untrusted data. If pickle is required, sign the payload with HMAC.
examples/projects/twitter/services/pathway-app/app/geocoding.py:69
low Security checks quality Quality conf 1.00 ✓ Repobility [MINED006] Overcatch Baseexception: except BaseException: ... — prevents Ctrl+C and SystemExit from working.
Review and fix per the pattern semantics. See CWE-705 / for context.
python/pathway/internals/interactive.py:110
low Security checks quality Quality conf 1.00 ✓ Repobility [MINED006] Overcatch Baseexception: except BaseException: ... — prevents Ctrl+C and SystemExit from working.
Review and fix per the pattern semantics. See CWE-705 / for context.
examples/projects/custom-python-connector-twitter/twitter_connector_example.py:63
high Security checks quality Quality conf 1.00 ✓ Repobility [MINED110] Blocking call `time.sleep` inside async function `lifespan`: `time.sleep` is a synchronous (blocking) call. When invoked inside an `async def` it stalls the event loop, preventing every other coroutine in the process from making progress.
Use the async equivalent: `aiohttp` instead of `requests`, `asyncio.sleep` instead of `time.sleep`, `aiofiles` instead of `open`.
python/pathway/web_dashboard/dashboard.py:26
high Security checks software dependencies conf 0.90 ✓ Repobility 22 occurrences [MINED118] Dockerfile FROM `python:3.10` not pinned by digest: `FROM python:3.10` resolves the tag at build time. The registry CAN re-push a different image for the same tag, so every build is potentially different. Production images should pin to `image@sha256:...` for reproducibility + supply-chain integrity.
Replace with: `FROM python:3.10@sha256:<digest>`. Get the digest from `docker manifest inspect`. Re-pin via a scheduled bot (Renovate, Dependabot).
12 files, 13 locations
examples/projects/twitter/services/frontend/Dockerfile:1, 14 (2 hits)
examples/projects/aws-fargate-deploy/Dockerfile:1
examples/projects/azure-aci-deploy/Dockerfile:1
examples/projects/best-movies-example/kafka-version/pathway-src/Dockerfile:1
examples/projects/best-movies-example/kafka-version/producer-src/Dockerfile:1
examples/projects/best-movies-example/redpanda-version/pathway-src/Dockerfile:1
examples/projects/best-movies-example/redpanda-version/producer-src/Dockerfile:1
examples/projects/from_jupyter_to_deploy/part4_deployment/Dockerfile:1
high Security checks software dependencies conf 0.90 ✓ Repobility 3 occurrences [MINED126] Workflow container/services image `quay.io/pypa/manylinux_2_28_x86_64:2026.02.01-1` unpinned: `container/services image: quay.io/pypa/manylinux_2_28_x86_64:2026.02.01-1` without `@sha256:...` pulls a mutable tag at workflow-run time. Treat workflow container references with the same supply-chain discipline as Dockerfile FROM lines.
Replace with `quay.io/pypa/manylinux_2_28_x86_64:2026.02.01-1@sha256:<digest>`. Re-pin via Dependabot Docker scope.
2 files, 3 locations
.github/workflows/release.yml:102, 161 (2 hits)
.github/workflows/package_test.yml:67
high Security checks security path traversal conf 0.80 [SEC013] Path Traversal — User Input in File Path: User-controlled input used in file path without sanitization. Allows reading arbitrary files.
Use os.path.realpath() and verify the path starts with your expected base directory. Use secure_filename() for uploads.
examples/projects/twitter/services/dataset-replayer/app/main.py:24
high Security checks security path traversal conf 0.80 [SEC013] Path Traversal — User Input in File Path: User-controlled input used in file path without sanitization. Allows reading arbitrary files.
Use os.path.realpath() and verify the path starts with your expected base directory. Use secure_filename() for uploads.
examples/projects/twitter/services/dataset-replayer/app/kafka-replayer.py:22
high Security checks cicd CI/CD security conf 0.90 3 occurrences Database service has no persistent data volume
Mount the database data directory to a named Docker volume or managed persistent disk, and document backup and restore testing.
3 files, 3 locations
examples/projects/debezium-mongodb-example/docker-compose.yml:2
examples/projects/debezium-postgres-example/docker-compose.yml:2
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:38
CI/CD securitycontainers
high Security checks cicd CI/CD security conf 0.84 5 occurrences Database service publishes a host port
Use `expose` for service-to-service access, bind to 127.0.0.1 for local-only access, or protect the port with firewall rules.
4 files, 5 locations
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:20, 38 (2 hits)
examples/projects/best-movies-example/kafka-version/docker-compose.yml:12
examples/projects/kafka-ETL/docker-compose.yml:12
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/docker-compose.yml:10
CI/CD securitycontainers
high Security checks cicd CI/CD security conf 0.95 3 occurrences Docker final stage runs as root
Create an application user after package installation and switch to it with USER appuser or USER 10001.
3 files, 3 locations
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/filebeat-src/Dockerfile:6
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/filebeat-src/Dockerfile:6
examples/projects/twitter/services/geocoder/Dockerfile:3
CI/CD securitycontainers
high System graph quality Integrity conf 1.00 Blocking `time.sleep(...)` inside `async def lifespan` — python/pathway/web_dashboard/dashboard.py:26
Sync I/O inside an async function blocks the event loop. While `time.sleep(...)` is running, *all* other coroutines on this loop are paused — silent throughput collapse under concurrency. Use the async equivalent (`httpx.AsyncClient`, `asyncio.sleep`, `aiofiles`) or wrap with `await asyncio.to_thre…
python/pathway/web_dashboard/dashboard.py:26 Sync io in asyncPerformance
high System graph security security conf 1.00 Insecure pattern 'eval_used' in python/pathway/internals/column.py:336
Found a known-risky pattern (eval_used). Review and replace if possible.
python/pathway/internals/column.py:336 Eval used
high System graph security security conf 1.00 Insecure pattern 'eval_used' in src/engine/dataflow.rs:1504
Found a known-risky pattern (eval_used). Review and replace if possible.
src/engine/dataflow.rs:1504 Eval used
high System graph security security conf 1.00 Insecure pattern 'eval_used' in src/engine/expression.rs:53
Found a known-risky pattern (eval_used). Review and replace if possible.
src/engine/expression.rs:53 Eval used
medium Security checks security auth conf 0.92 [AUC001] No Repobility access matrix policy found: The repository uses web/API frameworks but does not define .repobility/access.yml or equivalent authorization documentation.
Add .repobility/access.yml mapping routes to anonymous, authenticated, owner, admin, and super_admin. Keep business-specific rules in the repo so CI can enforce them.
medium Security checks security auth conf 0.72 [AUC012] FastAPI interactive docs may be exposed by framework defaults: FastAPI exposes /docs, /redoc, and /openapi.json by default. Public production APIs should explicitly disable those defaults, protect them behind admin authentication, or publish a reviewed OpenAPI spec with declared security requirements.
Set docs_url=None, redoc_url=None, and openapi_url=None for production apps unless the docs are intentionally public and protected by routing, ingress, or an authenticated docs handler.
medium Security checks quality Quality conf 1.00 ✓ Repobility 6 occurrences [MINED109] Mutable default argument in `run_sql` (list): `def run_sql(... = []/{}/set())` — Python's default value is constructed ONCE at function definition time and shared across all calls. Mutating it in one call mutates it for every future call too.
Use None as the default and create the collection inside the function: `def run_sql(x=None): x = x or []`
5 files, 6 locations
integration_tests/rag_evals/connector.py:55, 69 (2 hits)
examples/projects/twitter/services/api/app/api.py:25
examples/projects/twitter/services/pathway-app/app/geocoding.py:49
examples/projects/twitter/services/pathway-app/app/processing.py:65
python/pathway/xpacks/llm/question_answering.py:1214
medium Security checks quality Quality conf 1.00 ✓ Repobility 12 occurrences [MINED109] Mutable default argument in `run_with_querying` (dict): `def run_with_querying(... = []/{}/set())` — Python's default value is constructed ONCE at function definition time and shared across all calls. Mutating it in one call mutates it for every future call too.
Use None as the default and create the collection inside the function: `def run_with_querying(x=None): x = x or []`
7 files, 12 locations
python/pathway/xpacks/llm/splitters.py:80, 156, 173, 229 (4 hits)
python/pathway/xpacks/llm/parsers.py:112, 239, 297 (3 hits)
examples/projects/option-greeks/querying.py:68
integration_tests/rag_evals/connector.py:7
python/pathway/internals/expression_printer.py:136
python/pathway/xpacks/llm/_parser_utils.py:227
python/pathway/xpacks/llm/question_answering.py:1061
medium Security checks software dependencies conf 0.90 ✓ Repobility 25 occurrences [MINED124] requirements.txt: `pathway` has no version pin: Unpinned pip requirement means every fresh install may resolve a different version. Newer releases can introduce malicious code (typosquats, account compromises). Reproducible installs need exact pins.
Replace `pathway` with `pathway==<version>` and manage upgrades through PRs / Dependabot.
6 files, 25 locations
examples/projects/option-greeks/requirements.txt:1, 2, 3, 4, 5, 6, 7, 8, +1 more (9 hits)
examples/projects/azure-aci-deploy/requirements.txt:1, 2, 3, 4, 5 (5 hits)
integration_tests/rag_evals/requirements.txt:3, 6, 7, 8 (4 hits)
examples/projects/ag2-multiagent-rag/requirements.txt:1, 3, 4 (3 hits)
examples/projects/aws-fargate-deploy/requirements.txt:1, 2, 3 (3 hits)
examples/projects/spark-data-preparation/requirements.txt:1
low Security checks security Deserialization conf 1.00 3 occurrences [SEC007] Unsafe Deserialization: Unsafe deserialization can execute arbitrary code.
Use yaml.safe_load() instead of yaml.load(). Avoid pickle for untrusted data.
3 files, 3 locations
examples/projects/twitter/services/pathway-app/app/geocoding.py:69
python/pathway/internals/yaml_loader.py:151
python/pathway/stdlib/ml/hmm.py:200
medium Security checks quality Quality conf 1.00 [SEC123] Production stack trace / debug output exposed: Debug mode left on in production exposes stack traces, environment variables, framework internals — sometimes triggers RCE (Django debug page with arbitrary template eval).
Set DEBUG=False / APP_DEBUG=false in production. Provide a generic 500 handler that logs to backend but returns a sanitized page to clients.
docs/2.developers/4.user-guide/30.data-transformation/.custom_reducers/article.py:95
medium Security checks cicd CI/CD security conf 0.86 App service does not wait for database health
Give the database a healthcheck and change the dependency to `depends_on: { db: { condition: service_healthy } }`.
examples/projects/debezium-mongodb-example/docker-compose.yml:10 CI/CD securitycontainers
low Security checks quality Error handling conf 0.55 ✓ Repobility 5 occurrences Broad exception handler needs review
This handler catches Exception/BaseException. It is actionable when it swallows errors without logging, re-raising, or returning a structured error. Handlers that intentionally convert exceptions into typed error results should not be treated as high risk.
3 files, 5 locations
integration_tests/db_connectors/utils.py:631, 858, 1307 (3 hits)
integration_tests/rag_evals/experiment.py:34
integration_tests/s3/base.py:58
Error handlingquality
medium Security checks cicd CI/CD security conf 0.56 Compose service contains a literal secret environment value
Rotate the value if real. Move it to Docker Compose secrets, a platform secret manager, or an uncommitted environment file.
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:38 CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.56 Compose service contains a literal secret environment value
Rotate the value if real. Move it to Docker Compose secrets, a platform secret manager, or an uncommitted environment file.
examples/projects/debezium-postgres-example/docker-compose.yml:2 CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.86 Database dump or local database file is included in Docker build context
Move database dumps outside the Docker build context or exclude them with .dockerignore. Keep backup and restore artifacts in private object storage or a dedicated backup workflow.
.dockerignore CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.88 Database service has no healthcheck
Add a database-native healthcheck such as pg_isready, mysqladmin ping, redis-cli ping, or the vendor's readiness command.
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:38 CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.88 Database service has no healthcheck
Add a database-native healthcheck such as pg_isready, mysqladmin ping, redis-cli ping, or the vendor's readiness command.
examples/projects/debezium-postgres-example/docker-compose.yml:2 CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.74 14 occurrences Database service has no persistent data volume
Mount the database data directory to a named Docker volume or managed persistent disk, and document backup and restore testing.
7 files, 14 locations
examples/projects/best-movies-example/kafka-version/docker-compose.yml:6, 12 (2 hits)
examples/projects/debezium-mongodb-example/docker-compose.yml:16, 21 (2 hits)
examples/projects/debezium-postgres-example/docker-compose.yml:13, 18 (2 hits)
examples/projects/from_jupyter_to_deploy/part4_deployment/docker-compose.yml:3, 7 (2 hits)
examples/projects/kafka-ETL/docker-compose.yml:6, 12 (2 hits)
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/docker-compose.yml:6, 10 (2 hits)
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:16, 20 (2 hits)
CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.76 Docker build secret exposed through ARG
Replace secret ARG usage with `RUN --mount=type=secret,id=name ...` and pass the value with `docker build --secret`.
examples/projects/twitter/services/frontend/Dockerfile:6 CI/CD securitycontainers
high Security checks cicd CI/CD security conf 0.82 21 occurrences Docker final stage has no non-root USER
Add a non-root USER in the final runtime stage after files and permissions are prepared.
12 files, 12 locations
examples/projects/aws-fargate-deploy/Dockerfile:1
examples/projects/azure-aci-deploy/Dockerfile:1
examples/projects/best-movies-example/kafka-version/pathway-src/Dockerfile:1
examples/projects/best-movies-example/kafka-version/producer-src/Dockerfile:1
examples/projects/best-movies-example/redpanda-version/pathway-src/Dockerfile:1
examples/projects/best-movies-example/redpanda-version/producer-src/Dockerfile:1
examples/projects/debezium-mongodb-example/data-streaming/Dockerfile:1
examples/projects/debezium-mongodb-example/pathway-src/Dockerfile:1
CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.94 Dockerfile base image uses the latest tag
Pin to a maintained version tag or digest and update it deliberately through dependency automation.
examples/projects/web-scraping/Dockerfile:1 CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.94 Dockerfile base image uses the latest tag
Pin to a maintained version tag or digest and update it deliberately through dependency automation.
examples/projects/twitter/services/frontend/Dockerfile:1 CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.76 3 occurrences Dockerfile copies broad context with incomplete .dockerignore
Tighten .dockerignore or replace COPY . with explicit COPY statements.
3 files, 3 locations
examples/projects/from_jupyter_to_deploy/part4_deployment/Dockerfile:5
examples/projects/twitter/services/frontend/Dockerfile:12
examples/projects/web-scraping/Dockerfile:8
CI/CD securitycontainers
medium Security checks cicd CI/CD security conf 0.86 Dockerfile separates apt update from install
Combine update and install in the same RUN instruction and clean package indexes in that layer.
examples/projects/spark-data-preparation/Dockerfile:7 CI/CD securitycontainers
medium Security checks quality Quality conf 0.78 Public web service has no security.txt
Add /.well-known/security.txt with Contact, Expires, Canonical, Preferred-Languages, and Policy fields. Keep the contact endpoint monitored.
.well-known/security.txt
medium System graph quality Integrity conf 1.00 `fetch()` without try/.catch or AbortSignal — examples/projects/twitter/services/frontend/src/api.ts:38
Bare `fetch(...)` will throw an unhandled rejection on network failure. Wrap in try/catch, attach a `.catch(...)`, or pass an AbortSignal with a timeout.
runtime safetyRobustness
medium System graph hardware Supply chain conf 1.00 Docker base image uses a mutable or implicit tag: node:latest
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/twitter/services/frontend/Dockerfile:1 containersPinned dependencies
medium System graph hardware Supply chain conf 1.00 Docker base image uses a mutable or implicit tag: pathwaycom/pathway:latest
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/web-scraping/Dockerfile:1 containersPinned dependencies
medium System graph hardware Supply chain conf 1.00 Docker base image uses a mutable or implicit tag: pelias/placeholder
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/twitter/services/geocoder/Dockerfile:1 containersPinned dependencies
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/aws-fargate-deploy/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/azure-aci-deploy/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/best-movies-example/kafka-version/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/best-movies-example/kafka-version/producer-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/best-movies-example/redpanda-version/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/best-movies-example/redpanda-version/producer-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/debezium-mongodb-example/data-streaming/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/debezium-mongodb-example/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/debezium-postgres-example/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/from_jupyter_to_deploy/part4_deployment/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/kafka-ETL/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/kafka-ETL/producer-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/realtime-log-monitoring/filebeat-pathway-slack/filebeat-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/realtime-log-monitoring/filebeat-pathway-slack/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/realtime-log-monitoring/logstash-pathway-elastic/filebeat-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/realtime-log-monitoring/logstash-pathway-elastic/pathway-src/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/spark-data-preparation/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/twitter/services/api/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/twitter/services/dataset-replayer/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/twitter/services/frontend/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/twitter/services/geocoder/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/twitter/services/pathway-app/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/twitter/services/tweets-streamer/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph hardware Security conf 1.00 Dockerfile runs as root: examples/projects/web-scraping/Dockerfile
No non-root USER set. Containers running as root expand the blast radius of any vulnerability inside the image.
Container
medium System graph cicd CI/CD security conf 1.00 25 occurrences GitHub Action is tag-pinned rather than SHA-pinned
PyO3/maturin-action@v1 can move without a code change in this repo. Pin third-party actions to a reviewed 40-character commit SHA.
4 files, 25 locations
.github/workflows/release.yml:21, 28, 97, 126, 138, 156, 329, 363, +5 more (18 hits)
.github/workflows/package_test.yml:62, 91, 170 (3 hits)
.github/workflows/pull.yml:81, 93, 105 (3 hits)
external/timely-dataflow/.github/workflows/deploy.yml:15
CI/CD securitySupply chainGitHub Actions
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — examples/projects/from_jupyter_to_deploy/part4_deployment/dashboard.py:214
`requests.post(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — examples/projects/kafka-alternatives/benchmarks/benchmark.py:52
`subprocess.Popen(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — examples/projects/option-greeks/streamlit_ux.py:48
`requests.get(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — examples/projects/realtime-log-monitoring/filebeat-pathway-slack/pathway-src/alerts.py:73
`requests.post(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — python/pathway/_engine_finder.py:61
`subprocess.run(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — python/pathway/cli.py:139
`subprocess.Popen(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — python/pathway/io/slack/__init__.py:36
`requests.post(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — python/pathway/third_party/airbyte_serverless/executable_runner.py:234
`subprocess.Popen(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — python/pathway/third_party/airbyte_serverless/sources.py:160
`subprocess.run(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph security Coverage conf 1.00 No auth library detected
The scanner did not find any standard auth library (JWT, OAuth, NextAuth, Auth0, etc.). Either auth lives in custom code, in a separate service, or is missing.
auth
low Security checks cicd CI/CD security conf 0.72 .dockerignore misses sensitive defaults
Add missing patterns such as .env, .git, private keys, certificates, dependency folders, and local databases.
.dockerignore CI/CD securitycontainers
low Security checks cicd CI/CD security conf 0.68 9 occurrences App service does not wait for database health
Give the database a healthcheck and change the dependency to `depends_on: { db: { condition: service_healthy } }`.
6 files, 9 locations
examples/projects/best-movies-example/kafka-version/docker-compose.yml:31, 38 (2 hits)
examples/projects/from_jupyter_to_deploy/part4_deployment/docker-compose.yml:24, 33 (2 hits)
examples/projects/kafka-ETL/docker-compose.yml:31, 38 (2 hits)
examples/projects/debezium-mongodb-example/docker-compose.yml:42
examples/projects/debezium-postgres-example/docker-compose.yml:39
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:32
CI/CD securitycontainers
high Security checks cicd CI/CD security conf 0.56 17 occurrences Compose service does not declare a runtime user
Set a non-root `user:` in Compose or ensure the final image stage has a non-root USER directive.
9 files, 17 locations
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:2, 10, 32 (3 hits)
examples/projects/best-movies-example/kafka-version/docker-compose.yml:31, 38 (2 hits)
examples/projects/best-movies-example/redpanda-version/docker-compose.yml:32, 40 (2 hits)
examples/projects/debezium-mongodb-example/docker-compose.yml:10, 42 (2 hits)
examples/projects/from_jupyter_to_deploy/part4_deployment/docker-compose.yml:24, 33 (2 hits)
examples/projects/kafka-ETL/docker-compose.yml:31, 38 (2 hits)
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/docker-compose.yml:2, 22 (2 hits)
examples/projects/debezium-postgres-example/docker-compose.yml:39
CI/CD securitycontainers
high Security checks cicd CI/CD security conf 0.62 17 occurrences Compose service lacks no-new-privileges hardening
Add `security_opt: ["no-new-privileges:true"]` unless the service has a documented need for privilege escalation.
9 files, 17 locations
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:2, 10, 32 (3 hits)
examples/projects/best-movies-example/kafka-version/docker-compose.yml:31, 38 (2 hits)
examples/projects/best-movies-example/redpanda-version/docker-compose.yml:32, 40 (2 hits)
examples/projects/debezium-mongodb-example/docker-compose.yml:10, 42 (2 hits)
examples/projects/from_jupyter_to_deploy/part4_deployment/docker-compose.yml:24, 33 (2 hits)
examples/projects/kafka-ETL/docker-compose.yml:31, 38 (2 hits)
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/docker-compose.yml:2, 22 (2 hits)
examples/projects/debezium-postgres-example/docker-compose.yml:39
CI/CD securitycontainers
low Security checks cicd CI/CD security conf 0.72 14 occurrences Database service has no healthcheck
Add a database-native healthcheck such as pg_isready, mysqladmin ping, redis-cli ping, or the vendor's readiness command.
7 files, 14 locations
examples/projects/best-movies-example/kafka-version/docker-compose.yml:6, 12 (2 hits)
examples/projects/debezium-mongodb-example/docker-compose.yml:16, 21 (2 hits)
examples/projects/debezium-postgres-example/docker-compose.yml:13, 18 (2 hits)
examples/projects/from_jupyter_to_deploy/part4_deployment/docker-compose.yml:3, 7 (2 hits)
examples/projects/kafka-ETL/docker-compose.yml:6, 12 (2 hits)
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/docker-compose.yml:6, 10 (2 hits)
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/docker-compose.yml:16, 20 (2 hits)
CI/CD securitycontainers
low Security checks cicd CI/CD security conf 0.72 Dockerfile installs recommended OS packages
Add `--no-install-recommends` and explicitly list only packages the image needs.
examples/projects/spark-data-preparation/Dockerfile:8 CI/CD securitycontainers
high Security checks cicd CI/CD security conf 0.72 19 occurrences Dockerfile keeps pip download cache
Use `pip install --no-cache-dir ...` in container builds.
12 files, 16 locations
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/pathway-src/Dockerfile:3, 4, 5 (3 hits)
examples/projects/debezium-mongodb-example/data-streaming/Dockerfile:3, 4 (2 hits)
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/pathway-src/Dockerfile:3, 4 (2 hits)
examples/projects/aws-fargate-deploy/Dockerfile:6
examples/projects/azure-aci-deploy/Dockerfile:6
examples/projects/best-movies-example/kafka-version/pathway-src/Dockerfile:3
examples/projects/best-movies-example/kafka-version/producer-src/Dockerfile:3
examples/projects/best-movies-example/redpanda-version/pathway-src/Dockerfile:3
CI/CD securitycontainers
low Security checks quality Quality conf 0.60 30 occurrences Duplicated implementation block across source files
Duplicate implementation blocks are maintenance debt. Keep them visible, but they are not a high-severity defect unless the duplicated logic is security-sensitive or drifting.
12 files, 16 locations
external/differential-dataflow/tpchlike/src/queries/query10.rs:1, 38 (2 hits)
external/differential-dataflow/tpchlike/src/queries/query13.rs:21, 22 (2 hits)
external/differential-dataflow/tpchlike/src/queries/query16.rs:33, 34 (2 hits)
external/differential-dataflow/tpchlike/src/queries/query22.rs:42, 43 (2 hits)
external/differential-dataflow/src/operators/arrange/upsert.rs:58
external/differential-dataflow/src/operators/threshold.rs:58
external/differential-dataflow/src/trace/layers/mod.rs:106
external/differential-dataflow/src/trace/wrappers/enter_at.rs:62
duplicationquality
low System graph quality Maintenance conf 1.00 225 TODO/FIXME markers
High count of TODO/FIXME/HACK markers — track them as issues so they're not forgotten.
low System graph hardware Coverage conf 1.00 Containers defined but no K8s/orchestration manifest found
Repo has Dockerfiles/compose but no Kubernetes/Nomad manifests. If the target deployment is K8s, the manifests may live in a separate ops repo.
Deployment
low System graph hardware Supply chain conf 1.00 Docker base image is tag-pinned but not digest-pinned: docker.elastic.co/beats/filebeat:8.6.1
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/realtime-log-monitoring/filebeat-pathway-slack/filebeat-src/Dockerfile:1 containersPinned dependencies
low System graph hardware Supply chain conf 1.00 Docker base image is tag-pinned but not digest-pinned: docker.elastic.co/beats/filebeat:8.6.1
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/realtime-log-monitoring/logstash-pathway-elastic/filebeat-src/Dockerfile:1 containersPinned dependencies
low System graph hardware Supply chain conf 1.00 Docker base image is tag-pinned but not digest-pinned: nginx:stable-alpine
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/twitter/services/frontend/Dockerfile:14 containersPinned dependencies
low System graph hardware Supply chain conf 1.00 18 occurrences Docker base image is tag-pinned but not digest-pinned: python:3.10
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
12 files, 12 locations
examples/projects/aws-fargate-deploy/Dockerfile:1
examples/projects/azure-aci-deploy/Dockerfile:1
examples/projects/best-movies-example/kafka-version/pathway-src/Dockerfile:1
examples/projects/best-movies-example/kafka-version/producer-src/Dockerfile:1
examples/projects/best-movies-example/redpanda-version/pathway-src/Dockerfile:1
examples/projects/best-movies-example/redpanda-version/producer-src/Dockerfile:1
examples/projects/debezium-mongodb-example/data-streaming/Dockerfile:1
examples/projects/debezium-mongodb-example/pathway-src/Dockerfile:1
containersPinned dependencies
low System graph hardware Supply chain conf 1.00 Docker base image is tag-pinned but not digest-pinned: python:3.11
Container tags can be retagged upstream. Pin production base images to a reviewed digest (`image@sha256:...`) when reproducibility and supply-chain integrity matter.
examples/projects/from_jupyter_to_deploy/part4_deployment/Dockerfile:1 containersPinned dependencies
low System graph software Dead code candidate conf 1.00 File has no detected symbols: .github/ci/get-dependencies.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/best-movies-example/kafka-version/producer-src/create-stream.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/best-movies-example/redpanda-version/producer-src/create-stream.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/debezium-mongodb-example/data-streaming/streamer.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/kafka-alternatives/minio-ETL/base.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/realtime-log-monitoring/logstash-pathway-elastic/pathway-src/alerts.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/sharepoint-test/sharepoint_test.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/twitter/services/api/main.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/twitter/services/dataset-replayer/app/kafka-replayer.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/twitter/services/dataset-replayer/app/main.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/twitter/services/frontend/src/index.tsx
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: examples/projects/twitter/services/frontend/webpack.config.js
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: integration_tests/common/identity.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: integration_tests/common/unused_operators.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: integration_tests/common/unused_operators_2.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: integration_tests/common/used_operators.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: integration_tests/rag_evals/eval_questions.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/__main__.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/internals/version.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/internals/warnings.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/reducers.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/stdlib/indexing/colnames.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/tests/programs/debug.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/udfs.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/universes.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/web_dashboard/frontend/assets/index-BCRWi5Lr.js
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/xpacks/llm/_typing.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph software Dead code candidate conf 1.00 File has no detected symbols: python/pathway/xpacks/llm/constants.py
Source file with no class/function declarations — possible config, dead code, or scratch file.
low System graph cicd CI/CD security conf 1.00 26 occurrences GitHub Action is tag-pinned rather than SHA-pinned
actions/setup-python@v5 can move without a code change in this repo. Pin third-party actions to a reviewed 40-character commit SHA.
5 files, 26 locations
.github/workflows/pull.yml:20, 21, 31, 32, 42, 43, 69, 70, +3 more (11 hits)
.github/workflows/release.yml:64, 67, 174, 181, 188, 195, 218 (9 hits)
.github/workflows/package_test.yml:36, 39, 108, 133 (4 hits)
external/timely-dataflow/.github/workflows/deploy.yml:12
external/timely-dataflow/.github/workflows/test.yml:9
CI/CD securitySupply chainGitHub Actions
low System graph security security conf 1.00 Insecure pattern 'debug_true' in python/pathway/debug/__init__.py:52
Found a known-risky pattern (debug_true). Review and replace if possible.
python/pathway/debug/__init__.py:52 Debug true
low System graph quality Integrity conf 1.00 Near-duplicate function bodies in 10 places
Functions with the same first-5-line body hash: examples/projects/option-greeks/greeks-static.py:compute_delta, examples/projects/option-greeks/greeks-static.py:compute_gamma, examples/projects/option-greeks/greeks-static.py:compute_theta, examples/projects/option-greeks/greeks-static.py:compute_ve…
duplicatesduplication
low System graph quality Integrity conf 1.00 16 occurrences Near-duplicate function bodies in 2 places
Functions with the same first-5-line body hash: examples/projects/kafka-alternatives/benchmarks/lib.py:start, examples/projects/kafka-alternatives/benchmarks/lib.py:start This is *the* AI-coder failure mode (4× more duplication in vibe-coded repos — see https://jw.hn/ai-code-hygiene). Consolidate …
16 occurrences
repo-level (16 hits)
duplicatesduplication
low System graph quality Integrity conf 1.00 Near-duplicate function bodies in 3 places
Functions with the same first-5-line body hash: python/pathway/xpacks/llm/prompts.py:as_udf, python/pathway/xpacks/llm/prompts.py:as_udf, python/pathway/xpacks/llm/prompts.py:as_udf This is *the* AI-coder failure mode (4× more duplication in vibe-coded repos — see https://jw.hn/ai-code-hygiene). C…
duplicatesduplication
low System graph quality Integrity conf 1.00 2 occurrences Near-duplicate function bodies in 4 places
Functions with the same first-5-line body hash: examples/projects/option-greeks/greeks-static.py:compute_price, examples/projects/option-greeks/greeks-static.py:get_d1, examples/projects/option-greeks/greeks-replay.py:compute_price, examples/projects/option-greeks/greeks-replay.py:get_d1 This is *…
2 occurrences
repo-level (2 hits)
duplicatesduplication
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `_streaming_extra_col_unused` in integration_tests/db_connectors/test_mssql.py:1092
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `cuad_v1` in integration_tests/rag_evals/experiment.py:107
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `diff_v1` in python/pathway/tests/ordered/test_diff.py:62
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `item_copy` in integration_tests/db_connectors/test_questdb.py:169
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `iterated_copy` in python/pathway/internals/graph_runner/operator_handler.py:284
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `iterated_copy` in python/pathway/internals/graph_runner/storage_graph.py:202
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `iterated_copy` in python/pathway/internals/operator.py:328
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `list_objects_v2` in examples/projects/kafka-alternatives/benchmarks/benchmark.py:18
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `list_objects_v2` in examples/projects/kafka-alternatives/benchmarks/lib.py:124
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `list_objects_v2` in integration_tests/conftest.py:59
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `list_objects_v2` in integration_tests/wordcount/base.py:84
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `my_table_copy` in python/pathway/io/mysql/__init__.py:163
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `n_old` in integration_tests/kafka/test_rabbitmq.py:223
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `pubsub_v1` in python/pathway/io/pubsub/__init__.py:7
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `run_v2` in python/pathway/third_party/airbyte_serverless/sources.py:84
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `same_as_old` in python/pathway/internals/table.py:1974
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `table_to_legacy` in python/pathway/tests/test_api.py:26
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_copy` in python/pathway/tests/test_py_object_wrapper.py:317
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_psql_output_snapshot_legacy` in integration_tests/db_connectors/test_postgres.py:81
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_some_operators_unused` in integration_tests/common/test_common.py:8
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_timestamp_without_unit_deprecated` in python/pathway/tests/expressions/test_datetimes.py:187
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_update_old` in python/pathway/tests/ml/test_index.py:250
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_update_old` in python/pathway/tests/temporal/test_asof_now_joins.py:46
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `val_v1` in python/pathway/tests/temporal/test_asof_joins.py:120
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `warn_if_some_operators_unused` in python/pathway/internals/parse_graph.py:246
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `warn_if_some_operators_unused` in python/pathway/tests/test_common.py:24
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph software Dead code conf 1.00 Possibly dead Python function: add_random_shift
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/twitter/services/pathway-app/app/processing.py:40
low System graph software Dead code conf 1.00 Possibly dead Python function: compute_a
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/kafka-linear-regression/realtime_regression.py:64
low System graph software Dead code conf 1.00 Possibly dead Python function: compute_b
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/kafka-linear-regression/realtime_regression.py:72
low System graph software Dead code conf 1.00 Possibly dead Python function: consume_messages
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/kafka-alternatives/benchmarks/consumer.py:63
low System graph software Dead code conf 1.00 Possibly dead Python function: crop_to_max_length
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/llms.py:588
low System graph software Dead code conf 1.00 Possibly dead Python function: extract_author_login
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/spark-data-preparation/main.py:50
low System graph software Dead code conf 1.00 Possibly dead Python function: extract_commit_timestamp
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/spark-data-preparation/main.py:56
low System graph software Dead code conf 1.00 Possibly dead Python function: find_spec
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/_engine_finder.py:28
low System graph software Dead code conf 1.00 Possibly dead Python function: generic_transformer
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/document_store.py:197
low System graph software Dead code conf 1.00 Possibly dead Python function: geolocate_external
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/twitter/services/pathway-app/app/geocoding.py:49
low System graph software Dead code conf 1.00 Possibly dead Python function: handle
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/mcp_server.py:89
low System graph software Dead code conf 1.00 Possibly dead Python function: is_good_location
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/twitter/services/pathway-app/app/geocoding.py:102
low System graph software Dead code conf 1.00 Possibly dead Python function: parse_image
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/_parser_utils.py:180
low System graph software Dead code conf 1.00 Possibly dead Python function: parse_image_details
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/_parser_utils.py:227
low System graph software Dead code conf 1.00 Possibly dead Python function: pw_ai_answer
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/question_answering.py:1177
low System graph software Dead code conf 1.00 Possibly dead Python function: pw_ai_query
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/question_answering.py:680
low System graph software Dead code conf 1.00 Possibly dead Python function: pw_ai_summary
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/question_answering.py:1207
low System graph software Dead code conf 1.00 Possibly dead Python function: pw_list_documents
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/question_answering.py:1242
low System graph software Dead code conf 1.00 Possibly dead Python function: remove_emails
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/spark-data-preparation/main.py:42
low System graph software Dead code conf 1.00 Possibly dead Python function: replace_newline
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/parsers.py:1092
low System graph software Dead code conf 1.00 Possibly dead Python function: run_mcp
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/mcp_server.py:243
low System graph software Dead code conf 1.00 Possibly dead Python function: send_slack_alert
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/from_jupyter_to_deploy/part4_deployment/dashboard.py:209
low System graph software Dead code conf 1.00 Possibly dead Python function: start_pathway_server
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/ag2-multiagent-rag/main.py:56
low System graph software Dead code conf 1.00 Possibly dead Python function: stats_plotter
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
examples/projects/from_jupyter_to_deploy/part4_deployment/dashboard.py:155
low System graph software Dead code conf 1.00 Possibly dead Python function: wrapper
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
python/pathway/xpacks/llm/mcp_server.py:219
low System graph quality Integrity conf 1.00 Stub function `_initialize_from_context` (body is just `pass`/`return`) — python/pathway/internals/graph_runner/expression_evaluator.py:66
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `_null` (body is just `pass`/`return`) — python/pathway/internals/sql/processing.py:143
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `_operator_dependencies` (body is just `pass`/`return`) — python/pathway/internals/operator_input.py:15
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `_run` (body is just `pass`/`return`) — python/pathway/internals/graph_runner/operator_handler.py:91
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `_set_args` (body is just `pass`/`return`) — python/pathway/internals/dtype.py:135
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `callback` (body is just `pass`/`return`) — python/pathway/internals/desugaring.py:156
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `chunk` (body is just `pass`/`return`) — python/pathway/xpacks/llm/splitters.py:80
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `cli` (body is just `pass`/`return`) — python/pathway/cli.py:298
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `extract_text` (body is just `pass`/`return`) — python/pathway/xpacks/llm/parsers.py:1116
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `handle` (body is just `pass`/`return`) — python/pathway/io/http/_server.py:434
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `maybe_warn_in_windowby` (body is just `pass`/`return`) — python/pathway/internals/reducers.py:36
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `on_stop` (body is just `pass`/`return`) — python/pathway/third_party/airbyte_serverless/executable_runner.py:49
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `register_mcp` (body is just `pass`/`return`) — python/pathway/xpacks/llm/mcp_server.py:164
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `run` (body is just `pass`/`return`) — python/pathway/debug/__init__.py:504
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `to_transformer_column` (body is just `pass`/`return`) — python/pathway/internals/row_transformer.py:198
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph api Wiring conf 1.00 Unused endpoint: GET /get_table
`examples/projects/option-greeks/querying.py` declares `GET /get_table` but no frontend code we scanned calls it. This is fine if the endpoint serves external clients (mobile app, third-party, server-side webhooks). Otherwise it's dead code — consider removing or documenting who consumes it.
Unused endpoint
low System graph api Wiring conf 1.00 Unused endpoint: GET /graph
`python/pathway/web_dashboard/dashboard.py` declares `GET /graph` but no frontend code we scanned calls it. This is fine if the endpoint serves external clients (mobile app, third-party, server-side webhooks). Otherwise it's dead code — consider removing or documenting who consumes it.
Unused endpoint
low System graph api Wiring conf 1.00 Unused endpoint: GET /impact
`examples/projects/twitter/services/api/app/api.py` declares `GET /impact` but no frontend code we scanned calls it. This is fine if the endpoint serves external clients (mobile app, third-party, server-side webhooks). Otherwise it's dead code — consider removing or documenting who consumes it.
Unused endpoint
low System graph api Wiring conf 1.00 Unused endpoint: GET /referenced
`examples/projects/twitter/services/api/app/api.py` declares `GET /referenced` but no frontend code we scanned calls it. This is fine if the endpoint serves external clients (mobile app, third-party, server-side webhooks). Otherwise it's dead code — consider removing or documenting who consumes it.
Unused endpoint
low System graph api Wiring conf 1.00 Unused endpoint: GET /stats
`examples/projects/twitter/services/api/app/api.py` declares `GET /stats` but no frontend code we scanned calls it. This is fine if the endpoint serves external clients (mobile app, third-party, server-side webhooks). Otherwise it's dead code — consider removing or documenting who consumes it.
Unused endpoint
low System graph quality Complexity conf 1.00 Very large file: external/differential-dataflow/doop/src/main.rs (1239 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: external/differential-dataflow/src/operators/reduce.rs (1087 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: integration_tests/db_connectors/test_mongodb.py (1486 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: integration_tests/db_connectors/test_mssql.py (2697 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: integration_tests/db_connectors/test_postgres.py (4977 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: integration_tests/db_connectors/utils.py (1568 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: integration_tests/iceberg/test_iceberg.py (1729 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: integration_tests/kafka/test_simple.py (2568 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/internals/expressions/date_time.py (1651 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/internals/graph_runner/expression_evaluator.py (1592 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/internals/joins.py (1566 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/internals/table.py (3264 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/stdlib/temporal/_interval_join.py (1619 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/tests/test_common.py (6947 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/tests/test_io.py (4755 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/tests/test_sqlite.py (1557 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: python/pathway/xpacks/llm/parsers.py (1365 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/data_lake/delta.rs (1760 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/data_lake/iceberg.rs (1379 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/data_lake/mod.rs (1552 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/mssql.rs (2600 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/mysql.rs (1346 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/postgres.rs (4129 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/connectors/data_storage/sqlite.rs (1665 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/engine/dataflow.rs (7224 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/engine/expression.rs (1663 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/engine/graph.rs (1789 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: src/python_api.rs (7970 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
For AI agents: Voting guide (TP/FP) MCP manifest Stdio wrapper SARIF Integrate Findings queue Vote TP/FP on findings to calibrate the engine.
For AI agents + API integrations
Email me when this repo regresses
Free. We re-scan periodically; new criticals → your inbox. No signup required for the scan itself.
API access

This page is publicly accessible at: https://repobility.com/scan/49132254-95b6-49b4-a4d1-8a5245f14672/

To check status programmatically (no auth required):

curl -s https://repobility.com/api/v1/public/scan/49132254-95b6-49b4-a4d1-8a5245f14672/

Important — please don't re-submit the same URL repeatedly. The submission endpoint is idempotent: re-submitting the same git URL returns this same scan_token, not a new one. To re-scan this repo, sign up free and use the dashboard.