An orchestration platform for the development, production, and observation of data assets.
This report summarizes scanner evidence for dagster-io/dagster, a Python project with 16,259 GitHub stars. SynthScan examined 1,555,042 lines of code across 10944 source files, recording 21460 pattern matches distributed across 28 syntactic categories. The legacy adjusted pattern signal is 15.6 (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.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 16596 finding(s).
Are imports declared and package/API names verified? 3754 finding(s).
Are wrappers, guards, and repeated structures necessary? 15293 finding(s).
Which changes need focused human review? 21460 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
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.
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.
The scanner identified 21460 distinct pattern matches across 28 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.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | RUN_API_IMPLEMENTATION_PLAN.md | 269 | def get_run_events_via_graphql( | CODE |
| LOW | MIGRATION.md | 627 | def my_metadata_from_dbt_resource_props(dbt_resource_props): | CODE |
| LOW⚡ | …on_modules/dagster-test/dagster_test/toys/freshness.py | 22 | def asset_with_time_window_freshness_and_warning(): | CODE |
| LOW⚡ | …on_modules/dagster-test/dagster_test/toys/freshness.py | 31 | def asset_with_time_window_freshness_fast_fail(): | CODE |
| LOW⚡ | …on_modules/dagster-test/dagster_test/toys/freshness.py | 41 | def asset_with_cron_freshness_policy(): | CODE |
| LOW | …on_modules/dagster-test/dagster_test/toys/freshness.py | 52 | def asset_with_cron_freshness_policy_with_timezone(): | CODE |
| LOW | …on_modules/dagster-test/dagster_test/toys/freshness.py | 62 | def asset_with_cron_freshness_policy_short_cron_interval(): | CODE |
| LOW | …on_modules/dagster-test/dagster_test/toys/freshness.py | 73 | def asset_with_cron_freshness_policy_irregular_schedule(): | CODE |
| LOW | …thon_modules/dagster-test/dagster_test/toys/sensors.py | 101 | def custom_slack_on_job_failure(context: RunFailureSensorContext): | CODE |
| LOW | …odules/dagster-test/dagster_test/toys/error_monster.py | 67 | def define_errorable_resource(): | CODE |
| LOW | …odules/dagster-test/dagster_test/toys/data_versions.py | 15 | def observable_different_version(): | CODE |
| LOW⚡ | …odules/dagster-test/dagster_test/toys/data_versions.py | 43 | def has_code_version_multiple_deps(): ... | CODE |
| LOW⚡ | …odules/dagster-test/dagster_test/toys/data_versions.py | 47 | def downstream_of_code_versioned(): ... | CODE |
| LOW⚡ | …odules/dagster-test/dagster_test/toys/data_versions.py | 51 | def root_asset_no_code_version(context): | CODE |
| LOW⚡ | …odules/dagster-test/dagster_test/toys/data_versions.py | 56 | def downstream_of_no_code_version(): ... | CODE |
| LOW⚡ | …odules/dagster-test/dagster_test/toys/data_versions.py | 66 | def code_versioned_multi_asset(): | CODE |
| LOW⚡ | …odules/dagster-test/dagster_test/toys/data_versions.py | 72 | def downstream_of_code_versioned_multi_asset(): ... | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_checks.py | 98 | def asset_with_check_in_same_op(): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_checks.py | 144 | def random_fail_check_on_partitioned_asset(): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_checks.py | 222 | def stage_then_promote_graph_asset(): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_checks.py | 267 | def promote_staged_asset_with_tests(staged_asset): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_checks.py | 390 | def many_tests_graph_multi_asset(): | CODE |
| LOW | …_modules/dagster-test/dagster_test/toys/many_events.py | 76 | def many_table_materializations(_context): | CODE |
| LOW | …_modules/dagster-test/dagster_test/toys/many_events.py | 103 | def many_materializations_and_passing_expectations(_context): | CODE |
| LOW | …_modules/dagster-test/dagster_test/toys/many_events.py | 134 | def check_users_and_groups_one_fails_one_succeeds(_context): | CODE |
| LOW | …_modules/dagster-test/dagster_test/toys/many_events.py | 169 | def check_admins_both_succeed(_context): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_health.py | 48 | def downstream_of_always_fails(always_fails): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_health.py | 80 | def random_failure_partitioned_asset(context): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 128 | def always_materializes_check_sometimes_warns(context): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 136 | def always_materializes_check_sometimes_errors(context): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 144 | def observable_source_asset_always_observes(): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 149 | def observable_source_asset_execution_error(): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 154 | def observable_source_asset_random_execution_error(context): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_health.py | 166 | def asset_with_freshness_and_warning(): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 179 | def insert_source_asset_materializations(context: dg.OpExecutionContext) -> None: | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 184 | def insert_source_asset_materializations_job() -> None: | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 190 | def observe_no_def_observable(context): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 195 | def observe_no_def_observable_job(): | CODE |
| LOW⚡ | …modules/dagster-test/dagster_test/toys/asset_health.py | 200 | def materialize_no_def_materializable(context): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_health.py | 219 | def checks_no_def_materializable(context): | CODE |
| LOW | …modules/dagster-test/dagster_test/toys/asset_health.py | 230 | def materialize_no_def_materializable_job(): | CODE |
| LOW | …ules/dagster-test/dagster_test/toys/external_assets.py | 19 | def insert_materializations_job() -> None: | CODE |
| LOW | …les/dagster-test/dagster_test/toys/partition_config.py | 15 | def job_with_partition_config(): | CODE |
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 162 | def partitioned_assets_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 182 | def table_metadata_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 189 | def long_asset_keys_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 196 | def big_honkin_assets_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 205 | def upstream_assets_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 220 | def graph_backed_asset_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 225 | def assets_with_sensors_repository(): | CODE |
| LOW⚡ | python_modules/dagster-test/dagster_test/toys/repo.py | 230 | def conditional_assets_repository(): | CODE |
| LOW | …er-test/dagster_test/toys/seed_asset_failure_events.py | 154 | def seed_asset_failure_events(): | CODE |
| LOW | …les/dagster-test/dagster_test/toys/freshness_checks.py | 87 | def get_last_updated_timestamp_unreliable_source() -> TimestampMetadataValue: | CODE |
| LOW | …on_modules/dagster-test/dagster_test/toys/notebooks.py | 19 | def hello_world_notebook_pipeline(): | CODE |
| LOW | …s/dagster-test/dagster_test/toys/run_status_sensors.py | 48 | def yield_run_request_succeeds_sensor(context): | CODE |
| LOW | …s/dagster-test/dagster_test/toys/run_status_sensors.py | 66 | def return_run_request_succeeds_sensor(context): | CODE |
| LOW | …s/dagster-test/dagster_test/toys/run_status_sensors.py | 99 | def success_sensor_with_pipeline_run_reaction(context): | CODE |
| LOW | …s/dagster-test/dagster_test/toys/run_status_sensors.py | 105 | def yield_multi_run_request_success_sensor(context): | CODE |
| LOW | …s/dagster-test/dagster_test/toys/run_status_sensors.py | 125 | def return_multi_run_request_success_sensor(context): | CODE |
| LOW | …s/dagster-test/dagster_test/toys/run_status_sensors.py | 206 | def cross_repo_success_job_sensor(context): | CODE |
| 13919 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 24 | CODE | |
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 24 | CODE | |
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 28 | CODE | |
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 31 | CODE | |
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 83 | CODE | |
| LOW | python_modules/dagster-test/dagster_test/toys/repo.py | 85 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 1 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 2 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 3 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 4 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 5 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 6 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 7 | CODE | |
| LOW | …-test/dagster_test/toys/partitioned_assets/__init__.py | 8 | CODE | |
| LOW | …gster-test/dagster_test/toys/column_schema/__init__.py | 1 | CODE | |
| LOW | …t/dagster_test/utils/definitions_execute_in_process.py | 14 | CODE | |
| LOW | …t/dagster_test/utils/definitions_execute_in_process.py | 15 | CODE | |
| LOW | …dules/dagster-test/dagster_test/components/__init__.py | 1 | CODE | |
| LOW | …dules/dagster-test/dagster_test/components/__init__.py | 4 | CODE | |
| LOW | …dules/dagster-test/dagster_test/components/__init__.py | 7 | CODE | |
| LOW | …dules/dagster-test/dagster_test/components/__init__.py | 8 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …on_modules/dagster-graphql/dagster_graphql/__init__.py | 3 | CODE | |
| LOW | …les/dagster-graphql/dagster_graphql/schema/instance.py | 23 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/asset_graph.py | 87 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/asset_graph.py | 87 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/asset_graph.py | 87 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/asset_graph.py | 124 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/asset_graph.py | 124 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/asset_graph.py | 124 | CODE | |
| LOW | …ter-graphql/dagster_graphql/schema/schedule_dry_run.py | 22 | CODE | |
| LOW | …agster-graphql/dagster_graphql/schema/dagster_types.py | 23 | CODE | |
| LOW | …dagster-graphql/dagster_graphql/schema/asset_checks.py | 8 | CODE | |
| LOW | …les/dagster-graphql/dagster_graphql/schema/backfill.py | 64 | CODE | |
| LOW | …gster-graphql/dagster_graphql/schema/partition_sets.py | 7 | CODE | |
| LOW | …gster-graphql/dagster_graphql/schema/partition_sets.py | 57 | CODE | |
| LOW | …gster-graphql/dagster_graphql/schema/sensor_dry_run.py | 22 | CODE | |
| LOW | …odules/dagster-graphql/dagster_graphql/schema/table.py | 12 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/roots/query.py | 1 | CODE | |
| LOW | …/dagster-graphql/dagster_graphql/schema/logs/events.py | 27 | CODE | |
| LOW | …l/dagster_graphql/implementation/fetch_asset_checks.py | 46 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 34 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 34 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 34 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 44 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 47 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 48 | CODE | |
| LOW | …r-graphql/dagster_graphql/implementation/fetch_runs.py | 37 | CODE | |
| LOW | …ementation/fetch_auto_materialize_asset_evaluations.py | 15 | CODE | |
| LOW | …er-graphql/dagster_graphql/implementation/telemetry.py | 9 | CODE | |
| LOW | …ql/dagster_graphql/implementation/fetch_instigators.py | 16 | CODE | |
| LOW | …graphql/implementation/fetch_app_managed_components.py | 25 | CODE | |
| LOW | …graphql/implementation/fetch_app_managed_components.py | 26 | CODE | |
| LOW | …graphql/implementation/fetch_app_managed_components.py | 27 | CODE | |
| LOW | …graphql/implementation/fetch_app_managed_components.py | 41 | CODE | |
| 3410 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …hon_modules/libraries/dagster-rest-resources/README.md | 49 | ### Step 1: Define/Update Queries | COMMENT |
| LOW | …hon_modules/libraries/dagster-rest-resources/README.md | 76 | ### Step 2: Generate Code | COMMENT |
| LOW | …hon_modules/libraries/dagster-rest-resources/README.md | 87 | ### Step 3: Define Schema | COMMENT |
| LOW | …hon_modules/libraries/dagster-rest-resources/README.md | 110 | ### Step 4: Create API Class and Unit Tests | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 14 | # Step 1: Get presigned POST URL | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 23 | # Step 2: Upload file to S3 via presigned POST | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 33 | # Step 1: Get presigned GET URL | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 42 | # Step 2: Download file from S3 | COMMENT |
| LOW⚡ | …libraries/dagster-omni/dagster_omni_tests/test_defs.py | 240 | # Step 1: Fetch workspace data from "API" | COMMENT |
| LOW⚡ | …libraries/dagster-omni/dagster_omni_tests/test_defs.py | 246 | # Step 2: Build definitions from workspace data | COMMENT |
| LOW⚡ | …dagster-polytomic/dagster_polytomic_tests/test_defs.py | 279 | # Step 1: Fetch workspace data from "API" | COMMENT |
| LOW⚡ | …dagster-polytomic/dagster_polytomic_tests/test_defs.py | 282 | # Step 2: Build definitions from workspace data | COMMENT |
| LOW | …_backed_component_tests/test_state_backed_component.py | 425 | # Step 1: Start with versioned storage, no state available | COMMENT |
| LOW⚡ | …_backed_component_tests/test_state_backed_component.py | 449 | # Step 2: Run the update state job to populate versioned storage | COMMENT |
| LOW⚡ | …_backed_component_tests/test_state_backed_component.py | 453 | # Step 3: Reload with versioned storage - should have updated value | COMMENT |
| LOW | …_backed_component_tests/test_state_backed_component.py | 464 | # Step 4: Switch to local storage - should reset to initial value | COMMENT |
| LOW | …_backed_component_tests/test_state_backed_component.py | 488 | # Step 5: Load with DAGSTER_IS_DEV_CLI set - should force local refresh | COMMENT |
| LOW⚡ | …ons/declarative_automation/operators/since_operator.py | 139 | # Step 1: Add all newly-true trigger partitions | COMMENT |
| LOW⚡ | …ons/declarative_automation/operators/since_operator.py | 142 | # Step 2: Remove all newly-true reset partitions | COMMENT |
| LOW⚡ | …ons/declarative_automation/operators/since_operator.py | 145 | # Step 3: Use TimingMetadata to re-add partitions where trigger fired after reset | COMMENT |
| LOW⚡ | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 781 | # Step 3: Agent is stuck - actual == desired but _grpc_servers has an error | COMMENT |
| LOW⚡ | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 786 | # Step 4: Next workspace query - server reports no error (hasLoadError=False). | COMMENT |
| LOW⚡ | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 799 | # Step 5: Location should be healthy again | COMMENT |
| LOW | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 735 | # Step 1: Deploy successfully | COMMENT |
| LOW | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 749 | # Step 2: _refresh_actual_entries detects server moved to error state. | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 200 | # Step 0: Auto-prepare if requested | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 204 | # Step 1: Verify PR exists (skip if we have context) | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 212 | # Step 2: Update PR title | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 217 | # Step 3: Update PR body | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 222 | # Step 4: Update commit message | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 232 | # Step 5: Display success and Graphite URL | COMMENT |
| LOW | .claude/agents/pr-update-expert.md | 41 | ### Step 1: Repository Context Gathering | COMMENT |
| LOW | .claude/agents/pr-update-expert.md | 54 | ### Step 2: Thesis Collection Strategy | COMMENT |
| LOW | .claude/agents/pr-update-expert.md | 68 | ### Step 3: AI Analysis Generation | COMMENT |
| LOW | .claude/agents/pr-update-expert.md | 95 | ### Step 4: Atomic PR Update | COMMENT |
| LOW | .claude/commands/enforce_standards.md | 3 | ## Step 0: Stack Preparation with Merge Conflict Detection | COMMENT |
| LOW | .claude/commands/enforce_standards.md | 20 | ## Step 1: Invoke Code Standards Enforcer Agent | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 15 | ### Step 1: Detect Current Branch PR | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 22 | ### Step 2: Fetch All PR Comments | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 28 | ### Step 3: Identify Diamond Comments | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 38 | ### Step 4: Analyze Diamond Feedback | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 49 | ### Step 5: Create Action Plan | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 59 | ### Step 6: Present Comments for Review | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 69 | ### Step 7: Validate Comment Relevance | COMMENT |
| LOW⚡ | .claude/commands/analyze_diamond_feedback.md | 78 | ### Step 8: Mark Comments as Resolved | COMMENT |
| LOW | .claude/commands/analyze_diamond_feedback.md | 98 | ### Step 9: Generate Final Action Plan | COMMENT |
| LOW | .claude/commands/analyze_diamond_feedback.md | 104 | ### Step 10: Present Final Plan and Confirm | COMMENT |
| LOW | .claude/commands/analyze_diamond_feedback.md | 167 | # Step 1: Get Diamond review thread IDs for resolving conversations | COMMENT |
| LOW | .claude/commands/analyze_diamond_feedback.md | 193 | # Step 2: Filter for UNRESOLVED Diamond threads and extract thread IDs | COMMENT |
| LOW | .claude/commands/analyze_diamond_feedback.md | 201 | # Step 3: Resolve specific Diamond review thread conversations | COMMENT |
| LOW | .claude/commands/analyze_diamond_feedback.md | 213 | # Step 4: Batch resolve multiple Diamond threads | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/4-asset-checks.md | 13 | ## Step 1: Define an asset check | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/4-asset-checks.md | 35 | ## Step 2: Verify that the asset check runs | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/3-dependencies.md | 13 | ## Step 1: Create a downstream asset | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/3-dependencies.md | 27 | ## Step 2: Materialize the assets | COMMENT |
| LOW⚡ | docs/docs/dagster-basics-tutorial/1-assets.md | 13 | ## Step 1: Scaffold an assets file | COMMENT |
| LOW⚡ | docs/docs/dagster-basics-tutorial/1-assets.md | 23 | ## Step 2: Define the assets | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/1-assets.md | 43 | ## Step 3: Check definitions | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/1-assets.md | 61 | ## Step 4: Materialize the assets | COMMENT |
| LOW | docs/docs/dagster-basics-tutorial/5-schedules.md | 13 | ## Step 1: Scaffold a schedule definition | COMMENT |
| 564 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …hon_modules/dagster-test/dagster_test/toys/log_spew.py | 6 | CODE | |
| LOW | …hon_modules/dagster-test/dagster_test/toys/log_spew.py | 17 | CODE | |
| LOW | …st/dagster_test/toys/auto_materializing/large_graph.py | 33 | CODE | |
| LOW | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 301 | CODE | |
| LOW | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 361 | CODE | |
| LOW | …gster-test/dagster_test/test_project/test_jobs/repo.py | 88 | CODE | |
| LOW | …dagster-graphql/dagster_graphql/schema/config_types.py | 24 | CODE | |
| LOW | …dagster-graphql/dagster_graphql/schema/asset_health.py | 149 | CODE | |
| LOW | …gster-graphql/dagster_graphql/schema/partition_sets.py | 510 | CODE | |
| LOW | …gster-graphql/dagster_graphql/schema/partition_sets.py | 522 | CODE | |
| LOW | …ter-graphql/dagster_graphql/schema/pipelines/config.py | 95 | CODE | |
| LOW | …ter-graphql/dagster_graphql/schema/pipelines/config.py | 144 | CODE | |
| LOW | …ter-graphql/dagster_graphql/schema/pipelines/status.py | 23 | CODE | |
| LOW | …-graphql/dagster_graphql/schema/schedules/schedules.py | 141 | CODE | |
| LOW | …gster-graphql/dagster_graphql/schema/logs/log_level.py | 18 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 54 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/events.py | 234 | CODE | |
| LOW | …graphql/implementation/fetch_app_managed_components.py | 96 | CODE | |
| LOW | …graphql/implementation/fetch_app_managed_components.py | 151 | CODE | |
| LOW | …graphql/dagster_graphql/implementation/fetch_assets.py | 433 | CODE | |
| LOW | …agster-graphql/dagster_graphql/implementation/utils.py | 430 | CODE | |
| LOW | …gster-graphql/dagster_graphql/implementation/loader.py | 57 | CODE | |
| LOW | …gster_graphql/implementation/partition_status_utils.py | 140 | CODE | |
| LOW | …-graphql/dagster_graphql/implementation/fetch_ticks.py | 19 | CODE | |
| LOW | …l/dagster_graphql/implementation/execution/backfill.py | 92 | CODE | |
| LOW | …graphql/implementation/execution/dynamic_partitions.py | 59 | CODE | |
| LOW | …dules/dagster-graphql/dagster_graphql/client/client.py | 151 | CODE | |
| LOW | …hql_tests/graphql/test_definition_owner_permissions.py | 966 | CODE | |
| LOW | …hql_tests/graphql/test_definition_owner_permissions.py | 991 | CODE | |
| LOW | …-graphql/dagster_graphql_tests/graphql/test_context.py | 34 | CODE | |
| LOW | …lient_backcompat/test_backcompat_with_python_client.py | 15 | CODE | |
| LOW | …es/dagster-airbyte/dagster_airbyte/legacy_resources.py | 172 | CODE | |
| LOW | …es/dagster-airbyte/dagster_airbyte/legacy_resources.py | 555 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 61 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 186 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 256 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 420 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 230 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 363 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 524 | CODE | |
| LOW | …libraries/dagster-airbyte/dagster_airbyte/resources.py | 376 | CODE | |
| LOW | …ster-airbyte/dagster_airbyte/managed/reconciliation.py | 155 | CODE | |
| LOW | …ster-airbyte/dagster_airbyte/managed/reconciliation.py | 242 | CODE | |
| LOW | …agster-airbyte/dagster_airbyte_tests/test_resources.py | 80 | CODE | |
| LOW | …irbyte/dagster_airbyte_tests/test_generated_classes.py | 26 | CODE | |
| LOW | …-airbyte/dagster_airbyte_tests/test_cloud_resources.py | 60 | CODE | |
| LOW | …ter_airbyte_tests/integration/test_managed_elements.py | 47 | CODE | |
| LOW | …es/libraries/create-dagster/create_dagster/scaffold.py | 102 | CODE | |
| LOW | …ibraries/create-dagster/create_dagster/cli/scaffold.py | 71 | CODE | |
| LOW | …n_modules/libraries/dagster-dask/dagster_dask/utils.py | 188 | CODE | |
| LOW | …odules/libraries/dagster-dask/dagster_dask/executor.py | 168 | CODE | |
| LOW | …aries/dagster-snowflake/dagster_snowflake/resources.py | 701 | CODE | |
| LOW | …aries/dagster-snowflake/dagster_snowflake/resources.py | 746 | CODE | |
| LOW | …aries/dagster-snowflake/dagster_snowflake/resources.py | 786 | CODE | |
| LOW | …aries/dagster-snowflake/dagster_snowflake/resources.py | 827 | CODE | |
| LOW | …aries/dagster-snowflake/dagster_snowflake/resources.py | 967 | CODE | |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 806 | CODE | |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 899 | CODE | |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 1042 | CODE | |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 1075 | CODE | |
| 762 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …ules/dagster-graphql/dagster_graphql/schema/sensors.py | 0 | enable a schedule to launch runs for a job based on external state change. | STRING |
| HIGH | …gster-graphql/dagster_graphql/schema/sensor_dry_run.py | 0 | enable a schedule to launch runs for a job based on external state change. | STRING |
| HIGH | …ter-graphql/dagster_graphql/schema/schedule_dry_run.py | 0 | enable a schedule to launch runs for a job based on external state change. | STRING |
| HIGH | …er-snowflake/dagster_snowflake/snowflake_io_manager.py | 0 | returns a sql statement that deletes data in the given table to make way for the output data being written. | STRING |
| HIGH | …/libraries/dagster-duckdb/dagster_duckdb/io_manager.py | 0 | returns a sql statement that deletes data in the given table to make way for the output data being written. | STRING |
| HIGH | …braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py | 0 | returns a sql statement that deletes data in the given table to make way for the output data being written. | STRING |
| HIGH | …oject_fully_featured/resources/snowflake_io_manager.py | 0 | returns a sql statement that deletes data in the given table to make way for the output data being written. | STRING |
| HIGH | …er-snowflake/dagster_snowflake/snowflake_io_manager.py | 0 | {table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}' | STRING |
| HIGH | …ries/dagster-deltalake/dagster_deltalake/io_manager.py | 0 | {table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}' | STRING |
| HIGH | …/libraries/dagster-duckdb/dagster_duckdb/io_manager.py | 0 | {table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}' | STRING |
| HIGH | …braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py | 0 | {table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}' | STRING |
| HIGH | …s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py | 0 | query clideploymentsquery { fulldeployments { deploymentname deploymentid deploymenttype } } | STRING |
| HIGH | …raries/dagster-dg-cli/dagster_dg_cli/utils/plus/gql.py | 0 | query clideploymentsquery { fulldeployments { deploymentname deploymentid deploymenttype } } | STRING |
| HIGH | …gster-dg-cli/dagster_dg_cli/cli/plus/GRAPHQL_SCHEMA.md | 0 | query clideploymentsquery { fulldeployments { deploymentname deploymentid deploymenttype } } | STRING |
| HIGH | …ibraries/dagster-dlt/dagster_dlt/dlt_event_iterator.py | 0 | a wrapper around an iterator of sling events which contains additional methods for post-processing the events, such as f | STRING |
| HIGH | …r-fivetran/dagster_fivetran/fivetran_event_iterator.py | 0 | a wrapper around an iterator of sling events which contains additional methods for post-processing the events, such as f | STRING |
| HIGH | …es/dagster-sling/dagster_sling/sling_event_iterator.py | 0 | a wrapper around an iterator of sling events which contains additional methods for post-processing the events, such as f | STRING |
| HIGH | …/dagster_postgres/schedule_storage/schedule_storage.py | 0 | postgres-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery | STRING |
| HIGH | …gster-postgres/dagster_postgres/event_log/event_log.py | 0 | postgres-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery | STRING |
| HIGH | …r-postgres/dagster_postgres/run_storage/run_storage.py | 0 | postgres-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery | STRING |
| HIGH | …gster-postgres/dagster_postgres/event_log/event_log.py | 0 | store an event corresponding to a pipeline run. args: event (eventlogentry): the event to store. | STRING |
| HIGH | …gster/dagster/_core/storage/event_log/sql_event_log.py | 0 | store an event corresponding to a pipeline run. args: event (eventlogentry): the event to store. | STRING |
| HIGH | …odules/dagster/dagster/_core/storage/event_log/base.py | 0 | store an event corresponding to a pipeline run. args: event (eventlogentry): the event to store. | STRING |
| HIGH | python_modules/libraries/dagster-k8s/dagster_k8s/job.py | 0 | set this value if you are running the launcher within a k8s cluster. if ``true``, we assume the launcher is running with | STRING |
| HIGH | …es/libraries/dagster-k8s/dagster_k8s/ops/k8s_job_op.py | 0 | set this value if you are running the launcher within a k8s cluster. if ``true``, we assume the launcher is running with | STRING |
| HIGH | …raries/dagster-celery-k8s/dagster_celery_k8s/config.py | 0 | set this value if you are running the launcher within a k8s cluster. if ``true``, we assume the launcher is running with | STRING |
| HIGH | …s/dagster-k8s/dagster_k8s_tests/unit_tests/conftest.py | 0 | apiversion: v1 kind: config current-context: fake-context contexts: - context: cluster: fake-cluster name: fake-context | STRING |
| HIGH | …agster-celery-k8s/dagster_celery_k8s_tests/conftest.py | 0 | apiversion: v1 kind: config current-context: fake-context contexts: - context: cluster: fake-cluster name: fake-context | STRING |
| HIGH | …loud_tests/workspace_tests/test_kubernetes_launcher.py | 0 | apiversion: v1 kind: config current-context: fake-context contexts: - context: cluster: fake-cluster name: fake-context | STRING |
| HIGH | …s/dagster-k8s/dagster_k8s_tests/unit_tests/conftest.py | 0 | returns a str file path for a minimal kubeconfig file in the default location (~/.kube/config). | STRING |
| HIGH | …agster-celery-k8s/dagster_celery_k8s_tests/conftest.py | 0 | returns a str file path for a minimal kubeconfig file in the default location (~/.kube/config). | STRING |
| HIGH | …loud_tests/workspace_tests/test_kubernetes_launcher.py | 0 | returns a str file path for a minimal kubeconfig file in the default location (~/.kube/config). | STRING |
| HIGH | …/libraries/dagster-census/dagster_census/translator.py | 0 | a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve | STRING |
| HIGH | …ibraries/dagster-powerbi/dagster_powerbi/translator.py | 0 | a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve | STRING |
| HIGH | …raries/dagster-fivetran/dagster_fivetran/translator.py | 0 | a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve | STRING |
| HIGH | …ibraries/dagster-tableau/dagster_tableau/translator.py | 0 | a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve | STRING |
| HIGH | …itchen_sink_tests/integration_tests/test_e2e_mapped.py | 0 | test that assets can load properly, and that materializations register. | STRING |
| HIGH | …er-airlift/perf-harness/perf_harness_tests/test_e2e.py | 0 | test that assets can load properly, and that materializations register. | STRING |
| HIGH | …/dbt_example_tests/integration_tests/test_federated.py | 0 | test that assets can load properly, and that materializations register. | STRING |
| HIGH | …ample_tests/integration_tests/test_migration_stages.py | 0 | test that assets can load properly, and that materializations register. | STRING |
| HIGH | …ter_powerbi/components/power_bi_workspace/component.py | 0 | the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolver | STRING |
| HIGH | …ster-sigma/dagster_sigma/components/sigma_component.py | 0 | the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolver | STRING |
| HIGH | …er-looker/dagster_looker/api/components/translation.py | 0 | the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolver | STRING |
| HIGH | …ster-tableau/dagster_tableau/components/translation.py | 0 | the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolver | STRING |
| HIGH | …ter-gcp/dagster_gcp/dataproc/types_dataproc_cluster.py | 0 | note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \ | STRING |
| HIGH | …dagster-gcp/dagster_gcp/dataproc/types_dataproc_job.py | 0 | note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \ | STRING |
| HIGH | …r-gcp/dagster_gcp/dataproc/configs_dataproc_cluster.py | 0 | note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \ | STRING |
| HIGH | …gster-gcp/dagster_gcp/dataproc/configs_dataproc_job.py | 0 | note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \ | STRING |
| HIGH | …libraries/dagster-aws/dagster_aws/emr/configs_spark.py | 0 | note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \ | STRING |
| HIGH | …libraries/dagster-spark/dagster_spark/configs_spark.py | 0 | note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \ | STRING |
| HIGH | …as/dagster_duckdb_pandas/duckdb_pandas_type_handler.py | 0 | an i/o manager definition that reads inputs from and writes polars dataframes to duckdb. when using the duckdbpolarsioma | STRING |
| HIGH | …/dagster_duckdb_pyspark/duckdb_pyspark_type_handler.py | 0 | an i/o manager definition that reads inputs from and writes polars dataframes to duckdb. when using the duckdbpolarsioma | STRING |
| HIGH | …rs/dagster_duckdb_polars/duckdb_polars_type_handler.py | 0 | an i/o manager definition that reads inputs from and writes polars dataframes to duckdb. when using the duckdbpolarsioma | STRING |
| HIGH | …sql/dagster_mysql/schedule_storage/schedule_storage.py | 0 | mysql-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery whe | STRING |
| HIGH | …ies/dagster-mysql/dagster_mysql/event_log/event_log.py | 0 | mysql-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery whe | STRING |
| HIGH | …dagster-mysql/dagster_mysql/run_storage/run_storage.py | 0 | mysql-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery whe | STRING |
| HIGH | …sts/api_tests/asset_check_tests/test_business_logic.py | 0 | test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data | STRING |
| HIGH | …li_tests/api_tests/sensor_tests/test_business_logic.py | 0 | test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data | STRING |
| HIGH | …ts/api_tests/alert_policy_tests/test_business_logic.py | 0 | test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data | STRING |
| HIGH | …li_tests/api_tests/secret_tests/test_business_logic.py | 0 | test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data | STRING |
| 85 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …e/dagster_deltalake_tests/test_delta_table_resource.py | 30 | assert res.equals(data) | CODE |
| HIGH | …e/dagster_deltalake_tests/test_delta_table_resource.py | 67 | assert res.equals(data) | CODE |
| HIGH | …s/dagster-duckdb/dagster_duckdb_tests/test_resource.py | 23 | assert res.equals(sample_df) | CODE |
| HIGH | …er-dbt/dagster_dbt/components/dbt_project/component.py | 91 | This component assumes that you have already set up a dbt project, for example, the dbt `Jaffle shop <https://github | STRING |
| HIGH | …r-dbt/dagster_dbt_tests/perf_tests/test_import_perf.py | 42 | "`python -X importtime python_modules/libraries/dagster-dbt/dagster_dbt_tests/perf_tests/simple_import.py noop & | CODE |
| HIGH | …sts/unit_tests/in_airflow_tests/test_parse_metadata.py | 16 | "jsonString": '{"class_ref": {"class_name": "DefaultProxyToDagsterOperator", "module_path": "dagster_air | CODE |
| HIGH | …ake_pandas_tests/test_snowflake_pandas_type_handler.py | 178 | assert df.equals(DataFrame([{"col1": "a", "col2": 1}])) | CODE |
| HIGH | …ake_polars_tests/test_snowflake_polars_type_handler.py | 244 | assert df.equals(pl.DataFrame({"col1": ["a"], "col2": [1]})) | CODE |
| HIGH | …ing/dagster_sling_tests/perf_tests/test_import_perf.py | 43 | "`python -X importtime python_modules/libraries/dagster-sling/dagster_sling_tests/perf_tests/simple_import.py &> | CODE |
| HIGH | …_tests/cli_tests/import_perf_tests/test_import_perf.py | 64 | "`python -X importtime python_modules/libraries/dagster-dg-cli/dagster_dg_cli_tests/cli_tests/import_perf_tests/ | CODE |
| HIGH | …dg-cli/dagster_dg_cli/utils/yaml_template_generator.py | 67 | # If all options are null, return null | COMMENT |
| HIGH | …libraries/dagster-tableau/dagster_tableau/resources.py | 668 | # set them to null), which previously raised a KeyError and failed the load. | COMMENT |
| HIGH⚡ | …raries/dagster-spark/dagster_spark_tests/test_utils.py | 139 | pytest.param("a && b", ["a", "&&", "b"], id="chain-and"), | CODE |
| HIGH⚡ | …dules/dagster/dagster_tests/daemon_tests/test_types.py | 10 | ' "DaemonType.SENSOR"}, "error": {"__class__": "SerializableErrorInfo", "cause": null,' | CODE |
| HIGH⚡ | …dules/dagster/dagster_tests/daemon_tests/test_types.py | 11 | ' "cls_name": null, "message": "fizbuz", "stack": []}, "timestamp": 0.0}' | CODE |
| HIGH | …tion_tests/misc_execution_tests/test_asset_backfill.py | 1823 | r' "latest_storage_id": null, "serialized_requested_subset":' | CODE |
| HIGH | …tion_tests/misc_execution_tests/test_asset_backfill.py | 1836 | r' null, "serialized_requested_subset": {"partitions_subsets_by_asset_key": {},' | CODE |
| HIGH | …tion_tests/misc_execution_tests/test_asset_backfill.py | 1857 | r' []}, "latest_storage_id": null, "serialized_requested_subset":' | CODE |
| HIGH | …tests/definitions_tests/test_asset_check_evaluation.py | 8 | ' "AssetCheckSeverity.ERROR"}, "success": true, "target_materialization_data": null}' | CODE |
| HIGH | …ster_tests/definitions_tests/test_sensor_invocation.py | 1086 | assert ctx.cursor == "{\"AssetKey(['my_asset'])\": [null, 3, {}]}" | CODE |
| HIGH | …les/dagster/dagster_tests/general_tests/test_import.py | 50 | "`python -X importtime python_modules/dagster/dagster_tests/general_tests/import_cli.py &> /tmp/import.txt && tu | CODE |
| HIGH | …les/dagster/dagster_tests/general_tests/test_import.py | 90 | "`python -X importtime python_modules/dagster/dagster_tests/general_tests/simple.py &> /tmp/import.txt && tuna / | CODE |
| HIGH⚡ | …agster/dagster_tests/general_tests/test_serdes_pack.py | 494 | '"record_timestamp": "2026-04-06T11:49:19.912411+00:00", "update_timestamp": null}' | CODE |
| HIGH⚡ | …les/dagster/dagster_tests/general_tests/test_serdes.py | 530 | assert serialized == '{"__class__": "Foo", "color": "red", "shape": null}' | CODE |
| HIGH | …r_tests/general_tests/compat_tests/test_back_compat.py | 457 | old_event_record = """{"__class__":"EventRecord","dagster_event":{"__class__":"DagsterEvent","event_specific_data":n | CODE |
| HIGH | …r_tests/general_tests/compat_tests/test_dead_events.py | 20 | old_pipeline_init_failure_event = """{"__class__":"EventRecord","dagster_event":{"__class__":"DagsterEvent","event_s | CODE |
| HIGH⚡ | …/components_tests/resolution_tests/test_form_schema.py | 134 | # untouched, matching schemaPrep.ts. A non-string variant like {type: null} | COMMENT |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 162 | ' null, "bar": null, "baz": null, "metadata_entries": [{"__class__": "EventMetadataEntry",' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 163 | ' "description": null, "entry_data": {"__class__": "TextMetadataEntryData", "text": "999"},' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 165 | ' "message": "howdy", "pid": null, "pipeline_name": "nonce", "solid_handle": null,' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 166 | ' "step_handle": null, "step_key": "future_step", "step_kind_value": null}' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 170 | '{"__class__": "DagsterEvent", "event_specific_data": null, "event_type_value":' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 171 | ' "EVENT_TYPE_FROM_THE_FUTURE", "logging_tags": {}, "message": "howdy", "pid": null,' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 172 | ' "pipeline_name": "nonce", "solid_handle": null, "step_handle": null, "step_key":' | CODE |
| HIGH⚡ | …dagster/dagster_tests/core_tests/test_event_logging.py | 173 | ' "future_step", "step_kind_value": null}' | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 14 | {"__class__": "DagsterEvent", "event_specific_data": null, "event_type_value": "STEP_START", "logging_tags": {"pipeline" | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 16 | event_specific_data = {"step_output_handle": ["do_something", "result"], "type_check_data": [true, "result", null, []]} | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 21 | {"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepOutputData", "step_output_handle": {"__class__": | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 28 | {"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepSuccessData", "duration_ms": 13.93123900000015}, | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 34 | {"__class__": "DagsterEvent", "event_specific_data": null, "event_type_value": "STEP_START", "logging_tags": {"pipeline" | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 36 | event_specific_data = {"input_name": "x", "type_check_data": [true, "x", null, []]} | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 41 | {"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepInputData", "input_name": "x", "type_check_data" | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 43 | event_specific_data = {"step_output_handle": ["do_input", "result"], "type_check_data": [true, "result", null, []]} | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 48 | {"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepOutputData", "step_output_handle": {"__class__": | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 55 | {"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepSuccessData", "duration_ms": 13.923579000000075} | CODE |
| HIGH⚡ | …s/dagster/dagster_tests/core_tests/test_event_utils.py | 71 | lid": "do_input", "solid_definition": "do_input", "step_key": "do_input"}, "message": "Finished execution of step \\ | CODE |
| HIGH | …e_tests/snap_tests/test_old_execution_plan_snapshot.py | 9 | "initial_known_state": null, | CODE |
| HIGH | …e_tests/snap_tests/test_old_execution_plan_snapshot.py | 72 | "mapping_key": null, | CODE |
| HIGH | …e_tests/snap_tests/test_old_execution_plan_snapshot.py | 80 | "mapping_key": null, | CODE |
| HIGH | …e_tests/snap_tests/test_old_execution_plan_snapshot.py | 146 | "initial_known_state": null, | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1050 | '{"__class__": "ExternalSensorData", "description": null, "min_interval": null, "mode":' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1051 | ' "default", "name": "my_sensor", "pipeline_name": "my_pipeline", "solid_selection": null}' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1321 | ' null, "output_name": null, "partition_mapping": null}], "execution_type": {"__enum__":' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1322 | ' "AssetExecutionType.MATERIALIZATION"}, "pools": {"__set__": []}, "compute_kind": null,' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1323 | ' "op_name": "op_two", "op_names": ["op_two"], "code_version": null,' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1324 | ' "node_definition_name": null, "graph_name": null, "op_description": null, "job_names":' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1325 | ' ["a_job"], "partitions_def_data": null, "output_name": null, "metadata_entries": [],' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1326 | ' "tags": {}, "group_name": "some_group", "freshness_policy": null,' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1327 | ' "new_freshness_policy": null, "is_source": false, "is_observable": false,' | CODE |
| HIGH⚡ | …_tests/host_representation_tests/test_external_data.py | 1328 | ' "atomic_execution_unit_id": null, "required_top_level_resources": [],' | CODE |
| 58 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | conftest.py | 39 | except ImportError: | CODE |
| HIGH | conftest.py | 57 | except StopIteration: | CODE |
| HIGH | …n_modules/dagster-test/dagster_test_tests/test_toys.py | 98 | except IntentionalRandomFailure: | CODE |
| HIGH | …/libraries/dagster-airbyte/dagster_airbyte/__init__.py | 19 | except ImportError: | CODE |
| HIGH | …braries/dagster-deltalake/dagster_deltalake/handler.py | 96 | except Exception: | CODE |
| HIGH | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 134 | except Exception: | CODE |
| HIGH | …/libraries/dagster-duckdb/dagster_duckdb/io_manager.py | 264 | except duckdb.CatalogException: | CODE |
| HIGH | python_modules/libraries/dagster-celery/conftest.py | 14 | except ValueError: | CODE |
| HIGH | python_modules/libraries/dagster-celery/conftest.py | 20 | except ValueError: | CODE |
| HIGH | python_modules/libraries/dagster-celery/conftest.py | 26 | except ValueError: | CODE |
| HIGH | python_modules/libraries/dagster-celery/conftest.py | 32 | except ValueError: | CODE |
| HIGH | …raries/dagster-celery/dagster_celery_tests/conftest.py | 63 | except Exception: | CODE |
| HIGH | …raries/dagster-celery/dagster_celery_tests/conftest.py | 87 | except Exception: | CODE |
| HIGH | python_modules/libraries/dagster-airflow/conftest.py | 16 | except ValueError: | CODE |
| HIGH | python_modules/libraries/dagster-airflow/conftest.py | 22 | except ValueError: | CODE |
| HIGH | python_modules/libraries/dagster-airflow/conftest.py | 28 | except ValueError: | CODE |
| HIGH | …agster-airlift/dagster_airlift/test/shared_fixtures.py | 32 | except (OSError, subprocess.TimeoutExpired): | CODE |
| HIGH | …agster-airlift/dagster_airlift/test/shared_fixtures.py | 38 | except subprocess.TimeoutExpired: | CODE |
| HIGH | …/libraries/dagster-pandera/dagster_pandera/__init__.py | 38 | except ImportError: | CODE |
| HIGH | …r-pandas/dagster_pandas_tests/test_config_driven_df.py | 13 | except ImportError: | CODE |
| HIGH | …braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py | 404 | except NotFound: | CODE |
| HIGH | …/dagster-gcp/dagster_gcp_tests/pipes_tests/conftest.py | 31 | except exceptions.Conflict: | CODE |
| HIGH | …ies/dagster-mysql/dagster_mysql/event_log/event_log.py | 186 | except db_exc.IntegrityError: | CODE |
| HIGH | …/dagster_looker/lkml/dagster_looker_lkml_translator.py | 143 | except ParseError: | CODE |
| HIGH | …-databricks/dagster_databricks/databricks_step_main.py | 59 | except Empty: | CODE |
| HIGH | …ibraries/dagster-fivetran/dagster_fivetran/__init__.py | 42 | except ImportError: | CODE |
| HIGH | …ster_dg_cli_tests/cli_tests/test_check_yaml_command.py | 211 | except subprocess.TimeoutExpired: | CODE |
| HIGH | …li_tests/cli_tests/scaffold/branch/test_diagnostics.py | 383 | except ValueError: | CODE |
| HIGH | …r-dg-cli/dagster_dg_cli/cli/scaffold/github_actions.py | 60 | except Exception: | CODE |
| HIGH | …-dg-cli/dagster_dg_cli/cli/scaffold/build_artifacts.py | 55 | except Exception: | CODE |
| HIGH | …/dagster-aws/dagster_aws_tests/pipes_tests/fake_ecs.py | 228 | except self.cloudwatch_client.exceptions.ResourceAlreadyExistsException: | CODE |
| HIGH | …/dagster-aws/dagster_aws_tests/pipes_tests/fake_ecs.py | 236 | except self.cloudwatch_client.exceptions.ResourceAlreadyExistsException: | CODE |
| HIGH | …dagster-aws/dagster_aws_tests/pipes_tests/fake_glue.py | 166 | except self.cloudwatch_client.exceptions.ResourceAlreadyExistsException: | CODE |
| HIGH | …dagster-aws/dagster_aws_tests/pipes_tests/fake_glue.py | 174 | except self.cloudwatch_client.exceptions.ResourceAlreadyExistsException: | CODE |
| HIGH | …dagster-aws/dagster_aws_tests/pipes_tests/test_glue.py | 304 | except ProcessLookupError: | CODE |
| HIGH | …ibraries/dagster-aws/dagster_aws/cloudwatch/loggers.py | 125 | except Exception: | CODE |
| HIGH | …libraries/dagster-aws/dagster_aws/emr/emr_step_main.py | 81 | except Empty: | CODE |
| HIGH | …es/dagster-shared/dagster_shared/telemetry/__init__.py | 330 | except Exception: | CODE |
| HIGH | …es/dagster-shared/dagster_shared/telemetry/__init__.py | 82 | except FileExistsError: | CODE |
| HIGH | …libraries/dagster-shared/dagster_shared/plus/config.py | 89 | except Exception: | CODE |
| HIGH | …libraries/dagster-shared/dagster_shared/plus/config.py | 116 | except Exception: | CODE |
| HIGH | …ies/dagster-shared/dagster_shared/plus/config_utils.py | 35 | except Exception: | CODE |
| HIGH | …ies/dagster-shared/dagster_shared/plus/config_utils.py | 57 | except Exception: | CODE |
| HIGH | …ies/dagster-shared/dagster_shared/plus/config_utils.py | 79 | except Exception: | CODE |
| HIGH | …ark/components/spark_declarative_pipeline/discovery.py | 265 | except (json.JSONDecodeError, TypeError): | CODE |
| HIGH | …ark/components/spark_declarative_pipeline/discovery.py | 281 | except (json.JSONDecodeError, TypeError): | CODE |
| HIGH | …ark/components/spark_declarative_pipeline/discovery.py | 298 | except (json.JSONDecodeError, TypeError): | CODE |
| HIGH | …ponents/spark_declarative_pipeline/test_integration.py | 26 | except ModuleNotFoundError: | CODE |
| HIGH | …ponents/spark_declarative_pipeline/test_integration.py | 62 | except ModuleNotFoundError: | CODE |
| HIGH | …/dagster/dagster_tests/cli_tests/test_shutdown_pipe.py | 34 | except psutil.NoSuchProcess: | CODE |
| HIGH | …li_tests/workspace_tests/test_grpc_server_workspace.py | 191 | except DagsterUserCodeUnreachableError: | CODE |
| HIGH | python_modules/dagster/dagster/_utils/temp_file.py | 15 | except Exception: | CODE |
| HIGH | python_modules/dagster/dagster/_utils/schedules.py | 642 | except: | CODE |
| HIGH | …_modules/dagster/dagster/_utils/test/mysql_instance.py | 158 | except subprocess.CalledProcessError: | CODE |
| HIGH | …_modules/dagster/dagster/_utils/test/mysql_instance.py | 184 | except subprocess.CalledProcessError: | CODE |
| HIGH | python_modules/dagster/dagster/_grpc/server.py | 1759 | except CouldNotBindGrpcServerToAddress: | CODE |
| HIGH | python_modules/dagster/dagster/_grpc/server.py | 1905 | except DagsterUserCodeUnreachableError: | CODE |
| HIGH | python_modules/dagster/dagster/_grpc/impl.py | 251 | except: | CODE |
| HIGH | python_modules/dagster/dagster/_core/remote_origin.py | 368 | except DagsterUserCodeUnreachableError: | CODE |
| HIGH | python_modules/dagster/dagster/_core/utils.py | 216 | except TimeoutError: | CODE |
| 77 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …dules/dagster-graphql/dagster_graphql/client/client.py | 267 | Submits a job with attached configuration for execution. Args: job_name (str): The job's name | STRING |
| HIGH | …dules/dagster-graphql/dagster_graphql/client/client.py | 315 | Get the status of a given Pipeline Run. Args: run_id (str): run id of the requested pipeline run. | STRING |
| HIGH | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 1054 | The list of AssetsDefinition for all connections in the Airbyte workspace. Args: workspace (Union[AirbyteWo | STRING |
| HIGH | …libraries/dagster-airbyte/dagster_airbyte/resources.py | 573 | Returns a list of AssetSpecs representing the Airbyte content in the workspace. Args: dagster_airby | STRING |
| HIGH | …libraries/dagster-airbyte/dagster_airbyte/resources.py | 891 | Returns a list of AssetSpecs representing the Airbyte content in the workspace. Args: workspace (BaseAirbyt | STRING |
| HIGH | …libraries/dagster-airbyte/dagster_airbyte/resources.py | 969 | Returns a list of AssetSpecs representing the Airbyte content in the workspace. Args: workspace (AirbyteClo | STRING |
| HIGH | …s/libraries/dagster-github/dagster_github/resources.py | 175 | Retrieve the list of installations for the authenticated GitHub App. This method makes a GET request to the Git | STRING |
| HIGH | …s/libraries/dagster-github/dagster_github/resources.py | 243 | Execute a GraphQL query against the GitHub API. This method sends a POST request to the GitHub API with the pro | STRING |
| HIGH | …s/libraries/dagster-github/dagster_github/resources.py | 300 | Create a new issue in the specified GitHub repository. This method first retrieves the repository ID using the | STRING |
| HIGH | …s/libraries/dagster-github/dagster_github/resources.py | 343 | Create a new reference (branch) in the specified GitHub repository. This method first retrieves the repository | STRING |
| HIGH | …s/libraries/dagster-github/dagster_github/resources.py | 398 | Create a new pull request in the specified GitHub repository. This method creates a pull request from the head | STRING |
| HIGH | …er-snowflake/dagster_snowflake/snowflake_io_manager.py | 28 | Builds an IO manager definition that reads inputs from and writes outputs to Snowflake. Args: type_handlers | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 626 | Get a list of databases in Snowflake that match the specified pattern. Retrieves Database objects from Snowflak | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 665 | Get a list of schemas in Snowflake databases that match the specified patterns. Retrieves Schema objects from S | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 707 | Get a list of tables in Snowflake that match the specified patterns. Retrieves Table objects from Snowflake tha | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 747 | Get a list of views in Snowflake that match the specified patterns. Retrieves View objects from Snowflake that | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 787 | Get a list of pipes in Snowflake that match the specified patterns. Retrieves Pipe objects from Snowflake that | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 828 | Get a list of stages in Snowflake that match the specified patterns. Retrieves Stage objects from Snowflake tha | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 925 | Execute a query in Snowflake. Args: sql (str): the query to be executed parameters (Opt | STRING |
| HIGH | …aries/dagster-snowflake/dagster_snowflake/resources.py | 974 | Execute multiple queries in Snowflake. Args: sql_queries (str): List of queries to be executed in s | STRING |
| HIGH | …/libraries/dagster-duckdb/dagster_duckdb/io_manager.py | 29 | Builds an IO manager definition that reads inputs from and writes outputs to DuckDB. Args: type_handlers (S | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 108 | Given a parsed manifest and a dbt unique_id, returns the dictionary of properties for the corresponding dbt reso | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 326 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster asset key | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 411 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster descriptio | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 443 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster metadata f | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 475 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster tags for t | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 515 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster group name | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 547 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster code versi | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 579 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster owners for | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 614 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster :py:class: | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 669 | A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster :py:class: | STRING |
| HIGH | …ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py | 725 | [INTERNAL] A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster | STRING |
| HIGH | …dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py | 143 | Return the corresponding Dagster asset key for a dbt model, seed, or snapshot. Args: dbt_assets (AssetsDefi | STRING |
| HIGH | …dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py | 193 | Returns the corresponding Dagster asset keys for all tables in a dbt source. This is a convenience method that make | STRING |
| HIGH | …dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py | 252 | Returns the corresponding Dagster asset key for a dbt source with a singular table. Args: source_name (str) | STRING |
| HIGH | …dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py | 296 | Build an asset selection for a dbt selection string. See https://docs.getdbt.com/reference/node-selection/syntax#ho | STRING |
| HIGH | …dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py | 393 | Build a schedule to materialize a specified set of dbt resources from a dbt selection string. See https://docs.getd | STRING |
| HIGH | …ies/dagster-dbt/dagster_dbt/core/dbt_cli_invocation.py | 394 | Retrieve a dbt artifact from the target path. See https://docs.getdbt.com/reference/artifacts/dbt-artifacts for | STRING |
| HIGH | …les/libraries/dagster-dbt/dagster_dbt/core/resource.py | 508 | Create a subprocess to execute a dbt CLI command. Args: args (Sequence[str]): The dbt CLI command t | STRING |
| HIGH | …er-dbt/dagster_dbt/components/dbt_project/component.py | 254 | Given a parsed manifest and a dbt unique_id, returns the dictionary of properties for the corresponding dbt reso | STRING |
| HIGH | …/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py | 561 | Loads a set of dbt models, managed by a dbt Cloud job, into Dagster assets. In order to determine the set of dbt mod | STRING |
| HIGH | …s/libraries/dagster-dbt/dagster_dbt/cloud/resources.py | 187 | Updates specific properties of a dbt job. Documentation on the full set of potential parameters can be found he | STRING |
| HIGH | …ries/dagster-airlift/dagster_airlift/core/load_defs.py | 89 | Builds a :py:class:`dagster.Definitions` object from an Airflow instance. For every DAG in the Airflow instance, th | STRING |
| HIGH | …libraries/dagster-pandas/dagster_pandas/constraints.py | 679 | Factory for validators testing if column values are within a range. Args: minim(Optional[Comparable]): the | STRING |
| HIGH | …libraries/dagster-pandas/dagster_pandas/constraints.py | 795 | Factory for testing if the dtype of a val falls within some allowed set. Args: datatypes(Union[set[type], t | STRING |
| HIGH | …braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py | 37 | Builds an I/O manager definition that reads inputs from and writes outputs to BigQuery. Args: type_handlers | STRING |
| HIGH | …modules/libraries/dagster-ssh/dagster_ssh/resources.py | 27 | Creates a paramiko SSH key from a string. Args: key_str (str): A string containing the private key data. | STRING |
| HIGH | …tabricks/components/databricks_asset_bundle/configs.py | 50 | Load Databricks bundle configuration with template variables resolved. Uses the Databricks CLI to validate and reso | STRING |
| HIGH | …raries/dagster-fivetran/dagster_fivetran/asset_defs.py | 722 | The list of AssetsDefinition for all connectors in the Fivetran workspace. Args: workspace (FivetranWorkspa | STRING |
| HIGH | …braries/dagster-fivetran/dagster_fivetran/resources.py | 1165 | Returns a list of AssetSpecs representing the Fivetran content in the workspace. Args: dagster_five | STRING |
| HIGH | …braries/dagster-fivetran/dagster_fivetran/resources.py | 1283 | Executes a sync and poll process to materialize Fivetran assets. This method can only be used in the context | STRING |
| HIGH | …braries/dagster-fivetran/dagster_fivetran/resources.py | 1455 | Returns a list of AssetSpecs representing the Fivetran content in the workspace. Args: workspace (FivetranW | STRING |
| HIGH | …agster-sling/dagster_sling/dagster_sling_translator.py | 99 | A function that takes a stream definition from a Sling replication config and returns a Dagster AssetKey. | STRING |
| HIGH | …agster-sling/dagster_sling/dagster_sling_translator.py | 149 | A function that takes a stream definition from a Sling replication config and returns a Dagster AssetKey. | STRING |
| HIGH | …dg_cli_tests/cli_tests/api_tests/shared/yaml_loader.py | 12 | Load fixture scenarios from a YAML file. Args: yaml_file: Path to YAML file containing fixture scenario def | STRING |
| HIGH | …gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py | 26 | Run a git command and return the result. Args: args: List of git command arguments (without 'git' prefix) | STRING |
| HIGH | …gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py | 96 | Create and checkout a new git branch. Args: branch_name: Name of the branch to create Returns: | STRING |
| HIGH | …gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py | 126 | Create a commit with current changes and optionally push to remote. Args: message: Commit message l | STRING |
| HIGH | …gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py | 156 | Push the current branch to remote and create a GitHub pull request. Args: branch_name: Name of the branch t | STRING |
| HIGH | …-dg-cli/dagster_dg_cli/cli/scaffold/branch/planning.py | 64 | Generate initial implementation plan from user input. Args: context: Planning context with user inp | STRING |
| 57 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | RUN_API_IMPLEMENTATION_PLAN.md | 463 | except Exception as e: | CODE |
| LOW | RUN_API_IMPLEMENTATION_PLAN.md | 560 | except Exception as e: | CODE |
| LOW | …/dagster-graphql/dagster_graphql/schema/instigation.py | 447 | except Exception: | CODE |
| LOW | …/dagster-graphql/dagster_graphql/schema/instigation.py | 478 | except Exception: | CODE |
| LOW | …les/dagster-graphql/dagster_graphql/schema/backfill.py | 260 | except Exception: | CODE |
| LOW | …dules/dagster-graphql/dagster_graphql/schema/errors.py | 41 | except Exception as e: | STRING |
| LOW | …dules/dagster-graphql/dagster_graphql/schema/errors.py | 43 | except Exception as e: | STRING |
| LOW | …dules/dagster-graphql/dagster_graphql/schema/errors.py | 57 | except Exception as e: | STRING |
| LOW | …dules/dagster-graphql/dagster_graphql/schema/errors.py | 59 | except Exception as e: | STRING |
| LOW | …agster-graphql/dagster_graphql/implementation/utils.py | 575 | except Exception as exc: | CODE |
| LOW | …agster-graphql/dagster_graphql/implementation/utils.py | 589 | except Exception as exc: | CODE |
| LOW | …ter-graphql/dagster_graphql/implementation/external.py | 62 | except Exception: | CODE |
| LOW | …dules/dagster-graphql/dagster_graphql/client/client.py | 135 | except Exception as exc: # catch generic Exception from the gql client | CODE |
| LOW | …ules/dagster-graphql/dagster_graphql_tests/test_cli.py | 194 | except Exception as e: | STRING |
| MEDIUM | …/dagster-graphql/dagster_graphql_tests/graphql/repo.py | 547 | def throw_a_thing(): | CODE |
| LOW⚡ | …/dagster-graphql/dagster_graphql_tests/graphql/repo.py | 554 | except Exception as e: | CODE |
| LOW⚡ | …/dagster-graphql/dagster_graphql_tests/graphql/repo.py | 556 | except Exception as e: | CODE |
| LOW | …/dagster-graphql/dagster_graphql_tests/graphql/repo.py | 1243 | except Exception: | CODE |
| LOW | …er-snowflake/dagster_snowflake/snowflake_io_manager.py | 381 | except Exception as e: | CODE |
| LOW⚡ | …/dagster_snowflake/components/dbt_project/component.py | 634 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 321 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 765 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 833 | except Exception: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 890 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 1111 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 1121 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 1219 | except Exception as e: | CODE |
| LOW | …/dagster_snowflake/components/dbt_project/component.py | 1251 | except Exception as e: | CODE |
| LOW | …ter-cloud-cli/dagster_cloud_cli/core/graphql_client.py | 209 | except Exception as e: | CODE |
| LOW | …r-cloud-cli/dagster_cloud_cli/core/pex_builder/deps.py | 435 | except Exception as e: | CODE |
| LOW | …li/dagster_cloud_cli/core/pex_builder/code_location.py | 68 | except Exception: | CODE |
| LOW | …agster-cloud-cli/dagster_cloud_cli/commands/metrics.py | 99 | except Exception: | CODE |
| LOW | …ster-cloud-cli/dagster_cloud_cli/commands/ci/checks.py | 132 | except Exception as err: | CODE |
| LOW⚡ | …er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py | 340 | except Exception as error: | CODE |
| LOW⚡ | …er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py | 349 | except Exception as err: | CODE |
| LOW | …er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py | 375 | except Exception as err: | CODE |
| LOW | …er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py | 739 | except Exception as e: | CODE |
| LOW | …-cli/dagster_cloud_cli/commands/serverless/__init__.py | 440 | except Exception as e: | CODE |
| LOW⚡ | …gster_cloud_cli/commands/integration/atlan/__init__.py | 46 | except Exception as e: | CODE |
| LOW⚡ | …gster_cloud_cli/commands/integration/atlan/__init__.py | 62 | except Exception as e: | CODE |
| LOW | …d-cli/dagster_cloud_cli/commands/workspace/__init__.py | 45 | except Exception as e: | CODE |
| LOW | …d-cli/dagster_cloud_cli/commands/workspace/__init__.py | 150 | except Exception as e: | CODE |
| LOW | …d-cli/dagster_cloud_cli/commands/workspace/__init__.py | 160 | except Exception as e: | CODE |
| LOW | …d-cli/dagster_cloud_cli/commands/workspace/__init__.py | 222 | except Exception as e: | CODE |
| LOW | …d-cli/dagster_cloud_cli/commands/workspace/__init__.py | 357 | except Exception as e: | CODE |
| LOW | …oud_cli/commands/deployment/alert_policies/commands.py | 51 | except Exception as e: | CODE |
| LOW | …r-cloud-cli/dagster_cloud_cli/commands/job/__init__.py | 101 | except Exception as e: | CODE |
| LOW | …r-cloud-cli/dagster_cloud_cli/commands/run/__init__.py | 26 | except Exception as e: | CODE |
| LOW | …braries/dagster-deltalake/dagster_deltalake/handler.py | 96 | except Exception: | CODE |
| LOW | …braries/dagster-deltalake/dagster_deltalake/handler.py | 144 | except Exception as e: | CODE |
| LOW | …ibraries/dagster-dlt/dagster_dlt/dlt_event_iterator.py | 57 | except Exception as e: | CODE |
| LOW | …dagster-azure/dagster_azure/container_apps/launcher.py | 275 | except Exception: | CODE |
| LOW | …dagster-azure/dagster_azure/container_apps/launcher.py | 294 | except Exception as e: | CODE |
| LOW | …s/dagster-azure/dagster_azure/pipes/message_readers.py | 64 | except Exception: | CODE |
| LOW | …s/dagster-azure/dagster_azure/pipes/message_readers.py | 74 | except Exception: | CODE |
| MEDIUM | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 84 | def worker() -> None: | CODE |
| LOW⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 87 | except Exception as e: | CODE |
| LOW⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 134 | except Exception: | CODE |
| LOW | …on_modules/libraries/dagster-k8s/dagster_k8s/client.py | 548 | except Exception as e: | CODE |
| LOW | …on_modules/libraries/dagster-k8s/dagster_k8s/client.py | 554 | except Exception as e: | CODE |
| 455 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | …ests/graphql/components/test_app_managed_components.py | 378 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM⚡ | …ests/graphql/components/test_app_managed_components.py | 384 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM⚡ | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 1042 | # ----------------------- | COMMENT |
| MEDIUM⚡ | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 1044 | # ----------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 53 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 55 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 149 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 151 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 183 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 185 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 241 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 243 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 848 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/dagster_snowflake_tests/test_dbt_project_component.py | 850 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/dagster_snowflake_tests/test_dbt_project_component.py | 293 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/dagster_snowflake_tests/test_dbt_project_component.py | 295 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/dagster_snowflake_tests/test_dbt_project_component.py | 496 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/dagster_snowflake_tests/test_dbt_project_component.py | 498 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 19 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 21 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 38 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 40 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 73 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 75 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 102 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 104 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 142 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 144 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 178 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 180 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 207 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 209 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …gster-dbt/dagster_dbt_tests/cloud_v2/test_resources.py | 318 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …gster-dbt/dagster_dbt_tests/cloud_v2/test_resources.py | 320 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …raries/dagster-fivetran/dagster_fivetran/asset_defs.py | 711 | # ----------------------- | COMMENT |
| MEDIUM⚡ | …raries/dagster-fivetran/dagster_fivetran/asset_defs.py | 713 | # ----------------------- | COMMENT |
| MEDIUM | …braries/dagster-fivetran/dagster_fivetran/resources.py | 487 | # ------------------ | COMMENT |
| MEDIUM | …braries/dagster-fivetran/dagster_fivetran/resources.py | 489 | # ------------------ | COMMENT |
| MEDIUM | …i_tests/cli_tests/api_tests/run_tests/test_get_logs.py | 125 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …i_tests/cli_tests/api_tests/run_tests/test_get_logs.py | 127 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …_tests/cli_tests/api_tests/run_tests/test_get_ticks.py | 15 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …_tests/cli_tests/api_tests/run_tests/test_get_ticks.py | 17 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …_tests/cli_tests/api_tests/run_tests/test_get_ticks.py | 92 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …_tests/cli_tests/api_tests/run_tests/test_get_ticks.py | 94 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …_tests/cli_tests/api_tests/run_tests/test_get_ticks.py | 159 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …_tests/cli_tests/api_tests/run_tests/test_get_ticks.py | 161 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 175 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 177 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 256 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 258 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 1103 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 1105 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 107 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 109 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 136 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 138 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 193 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 195 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 206 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py | 208 | # --------------------------------------------------------------------------- | COMMENT |
| 93 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | conftest.py | 44 | # Create a section break in the logs any time Buildkite invokes pytest | COMMENT |
| MEDIUM | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 344 | # Create a venv capable of running dagster dev | COMMENT |
| MEDIUM | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 830 | # Create a buffer for the result | COMMENT |
| MEDIUM | …r-graphql/dagster_graphql_tests/graphql/test_assets.py | 3834 | # Create a context with permissions in one location | COMMENT |
| MEDIUM | …phql_tests/graphql/test_asset_condition_evaluations.py | 850 | # Create an evaluation with SinceCondition metadata | COMMENT |
| MEDIUM | …-graphql/dagster_graphql_tests/graphql/test_context.py | 85 | # Create a request context from the process context | COMMENT |
| MEDIUM | …ql/dagster_graphql_tests/graphql/test_captured_logs.py | 124 | # Create a unique log key for this test | STRING |
| MEDIUM | …ql/dagster_graphql_tests/graphql/test_captured_logs.py | 172 | # Create a unique log key for this test | STRING |
| MEDIUM | …libraries/dagster-airbyte/dagster_airbyte/resources.py | 468 | """This class represents a Airbyte workspace and provides utilities | STRING |
| MEDIUM | …r-airbyte/dagster_airbyte_tests/beta/test_resources.py | 428 | # Create a new resource with the specific cancel_on_termination value | COMMENT |
| MEDIUM | …r-airbyte/dagster_airbyte_tests/beta/test_resources.py | 530 | # Create a new resource with the specific poll_previous_running_sync value | COMMENT |
| MEDIUM | …rbyte_tests/test_airbyte_project/api_http_headers.yaml | 1 | # This file is an example file with API HTTP headers used to pass to the octavia CLI API client. | COMMENT |
| MEDIUM | …dules/libraries/dagster-dask/dagster_dask/resources.py | 27 | # Create a Dask cluster if a cluster config is specified. | COMMENT |
| MEDIUM | …s/libraries/dagster-snowflake/dagster_snowflake/ops.py | 27 | """This function is a solid factory that constructs solids to execute a snowflake query. | STRING |
| MEDIUM | …s/libraries/dagster-snowflake/dagster_snowflake/ops.py | 45 | """This function is an op factory that constructs an op to execute a snowflake query. | STRING |
| MEDIUM | …ies/dagster-snowflake/dagster_snowflake_tests/utils.py | 65 | # Create a temporary table to base the view on | COMMENT |
| MEDIUM | …ies/dagster-snowflake/dagster_snowflake_tests/utils.py | 98 | # Create a temporary table and stage for the pipe | COMMENT |
| MEDIUM | …ies/dagster-snowflake/dagster_snowflake_tests/utils.py | 137 | # Create an internal stage | COMMENT |
| MEDIUM | …dagster_cloud_cli_tests/test_pyproject_toml_support.py | 365 | # Create a project with pyproject.toml | COMMENT |
| MEDIUM | …dagster_cloud_cli_tests/test_pyproject_toml_support.py | 598 | # Create main package | COMMENT |
| MEDIUM | …dagster_cloud_cli_tests/test_pyproject_toml_support.py | 338 | # Create a simple Python file | STRING |
| MEDIUM | …dagster_cloud_cli_tests/test_pyproject_toml_support.py | 396 | # Create a nested package structure like: | STRING |
| MEDIUM | …dagster_cloud_cli_tests/test_pyproject_toml_support.py | 469 | # Create a requirements.txt that setup.py will read | STRING |
| MEDIUM | …dagster_cloud_cli_tests/test_pyproject_toml_support.py | 736 | # Create main app package | STRING |
| MEDIUM | …braries/dagster-deltalake/dagster_deltalake/handler.py | 278 | # Create a dataset from actions table and apply filter | COMMENT |
| MEDIUM | …dagster_gcp_pandas_tests/bigquery/test_type_handler.py | 158 | # Create a job with the temporary table name as an output, so that it will write to that table | COMMENT |
| MEDIUM | …on_modules/libraries/dagster-k8s/dagster_k8s/models.py | 16 | # Create a single Configuration object to pass through to each model creation - | COMMENT |
| MEDIUM | …es/libraries/dagster-k8s/dagster_k8s/ops/k8s_job_op.py | 172 | """This function is a utility for executing a Kubernetes job from within a Dagster op. | STRING |
| MEDIUM⚡ | …dagster-k8s/dagster_k8s_tests/unit_tests/test_pipes.py | 479 | # Create a mock message reader that is an instance of PipesK8sPodLogsMessageReader | COMMENT |
| MEDIUM | …agster-k8s/dagster_k8s_tests/unit_tests/test_models.py | 151 | # Creating a model should not use the logger lock | COMMENT |
| MEDIUM | …agster_gcp_pyspark_tests/bigquery/test_type_handler.py | 210 | # Create a job with the temporary table name as an output, so that it will write to that table | COMMENT |
| MEDIUM | …ibraries/dagster-dbt/dagster_dbt/cloud_v2/resources.py | 78 | """This class represents a dbt Cloud workspace and provides utilities | STRING |
| MEDIUM | …ies/dagster-dbt/dagster_dbt/core/dbt_cli_invocation.py | 180 | # Create a subprocess that runs the dbt CLI command. | COMMENT |
| MEDIUM⚡ | …es/libraries/dagster-dbt/dagster_dbt_tests/conftest.py | 201 | # Create the source_raw_customers table in DuckDB before dbt runs. | COMMENT |
| MEDIUM | …es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh | 391 | # Create the directory if it doesn't exist | COMMENT |
| MEDIUM | …gster-dbt/dagster_dbt_tests/cloud_v2/test_resources.py | 122 | # Create a workspace with custom ad hoc job name | COMMENT |
| MEDIUM | …gster-dbt/dagster_dbt_tests/core/test_temp_selector.py | 210 | # Create a large select expression that exceeds the threshold when combined with exclude | STRING |
| MEDIUM | …-dbt/dagster_dbt_tests/cli/test_prepare_and_package.py | 209 | # Create a dependencies.yml file | COMMENT |
| MEDIUM | …libraries/dagster-airlift/dagster_airlift/mwaa/auth.py | 81 | # Create a new session | COMMENT |
| MEDIUM | …unit_tests/in_airflow_tests/test_no_dagster_install.py | 18 | # Create a new virtual environment using uv | COMMENT |
| MEDIUM | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 423 | # Create an actual run for the monitoring job that is not finished. | COMMENT |
| MEDIUM | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 570 | # Create an actual run for the monitoring job that is failed. | COMMENT |
| MEDIUM | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 581 | # Create a successful run for the monitoring job within the same run group. | COMMENT |
| MEDIUM | …les/libraries/dagster-airlift/scripts/airflow_setup.sh | 20 | # Create the airflow.cfg file in the specified AIRFLOW_HOME_DIR | COMMENT |
| MEDIUM | …aries/dagster-airlift/perf-harness/perf_harness/cli.py | 81 | # Create an ephemeral file where the results will be written, and assign it in shared.constants.py | COMMENT |
| MEDIUM | …lift/perf-harness/perf_harness/dagster_defs/observe.py | 30 | # Create a bunch of dependencies for each asset. | COMMENT |
| MEDIUM | …lift/perf-harness/perf_harness/dagster_defs/migrate.py | 37 | # Create a bunch of dependencies for each asset. | COMMENT |
| MEDIUM | …ake_pandas_tests/test_snowflake_pandas_type_handler.py | 225 | # Create a job with the temporary table name as an output, so that it will write to that table | COMMENT |
| MEDIUM | …libraries/dagster-pandas/dagster_pandas/constraints.py | 426 | """This class is useful for constructing single constraints that you want to apply to multiple | STRING |
| MEDIUM | …libraries/dagster-pandas/dagster_pandas/constraints.py | 481 | """This class is useful for constructing more complicated relationships between columns | STRING |
| MEDIUM | …libraries/dagster-pandas/dagster_pandas/constraints.py | 564 | """This class is similar to multicolumn, but takes in functions that operate on the whole column at once | STRING |
| MEDIUM | …ake_polars_tests/test_snowflake_polars_type_handler.py | 268 | # Create a job with the temporary table name as an output, so that it will write to that table | COMMENT |
| MEDIUM | …gcp/dagster_gcp_tests/dataproc_tests/test_resources.py | 122 | # Create a single-node cluster | COMMENT |
| MEDIUM | …gcp/dagster_gcp_tests/dataproc_tests/test_resources.py | 175 | # Create a single-node cluster | COMMENT |
| MEDIUM | …gcp/dagster_gcp_tests/dataproc_tests/test_resources.py | 231 | # Create a single-node cluster | COMMENT |
| MEDIUM | …gcp/dagster_gcp_tests/dataproc_tests/test_resources.py | 284 | # Create a single-node cluster | COMMENT |
| MEDIUM | …gcp/dagster_gcp_tests/dataproc_tests/test_resources.py | 331 | # Create a single-node cluster | COMMENT |
| MEDIUM | …s/dagster-sigma/dagster_sigma_tests/test_translator.py | 140 | # Create a workbook that references a table inode that doesn't exist | COMMENT |
| MEDIUM | …sql/dagster_mysql/schedule_storage/schedule_storage.py | 188 | # Define the base insert statement | COMMENT |
| MEDIUM | …sql/dagster_mysql/schedule_storage/schedule_storage.py | 201 | # Define the upsert statement using the ON DUPLICATE KEY UPDATE syntax for MySQL | COMMENT |
| 130 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | pyproject.toml | 154 | # Project-scaffold templates; the PROJECT_NAME_PLACEHOLDER is substituted at generation time. | COMMENT |
| MEDIUM | README.md | 103 | ### Dagster as a robust orchestration engine | COMMENT |
| MEDIUM | CHANGES.md | 1544 | ### `create-dagster` — one-shot project scaffold | COMMENT |
| MEDIUM | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 899 | # We need to find the right spot to inject global options. For the `dg scaffold` | COMMENT |
| MEDIUM | …es/libraries/create-dagster/create_dagster/scaffold.py | 29 | # add create-dagster to editable installs so you can scaffold projects in the | COMMENT |
| MEDIUM | …gster_dlt/components/dlt_load_collection/scaffolder.py | 126 | # Given source and destination, we can use dlt init to scaffold the source | COMMENT |
| MEDIUM | python_modules/libraries/dagster-soda/README.md | 27 | Use the Dagster CLI to scaffold a new Soda scan component in your project (requires [dagster-dg-cli](https://docs.dagste | CODE |
| MEDIUM | …es/dagster-soda/dagster_soda_tests/test_integration.py | 100 | # Default scaffold uses "my_table" in checks and asset_key_map | COMMENT |
| MEDIUM | …/libraries/dagster-pandera/dagster_pandera/__init__.py | 16 | # However, some commented-out scaffolding has been left in place for support of | COMMENT |
| MEDIUM | …es/dagster-fivetran/dagster_fivetran/sensor_builder.py | 147 | # New successful sync — check if the orchestration path already materialized this sync | COMMENT |
| MEDIUM | …raries/dagster-fivetran/dagster_fivetran/translator.py | 343 | # the polling sensor and Dagster-triggered (orchestration) syncs. | COMMENT |
| MEDIUM | …r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py | 136 | # Simulate orchestration having already written materializations | COMMENT |
| MEDIUM | …r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py | 203 | # Simulate orchestration materialized sync A (NEW_SYNC_TIME_STR) | COMMENT |
| MEDIUM | …r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py | 217 | # Set cursor to sync A's timestamp (orchestration already handled it) | COMMENT |
| MEDIUM⚡ | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 436 | # runner.invoke("scaffold", "component", "Baz") | COMMENT |
| MEDIUM⚡ | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 437 | # assert_runner_result(runner.invoke("scaffold", "component", "Baz")) | COMMENT |
| MEDIUM | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 213 | # dg scaffold defs foo_bar.components.baz.Baz should still work | COMMENT |
| MEDIUM⚡ | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 861 | # SimplePipesScriptComponent has scaffold params, so --json-params should be defined | STRING |
| MEDIUM⚡ | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 868 | # AllMetadataEmptyComponent does not have scaffold params, so --json-params should not be | STRING |
| MEDIUM | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 765 | # First, try scaffolding with multiple options using --asset-key | STRING |
| MEDIUM | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 829 | # Check for simple job scaffolding | STRING |
| MEDIUM | …_dg_cli_tests/cli_tests/test_environment_validation.py | 188 | # `dg scaffold` is special because global options have to be inserted before the | COMMENT |
| MEDIUM | …ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py | 42 | # The `dg scaffold defs` command is special because its subcommands are dynamically generated | COMMENT |
| MEDIUM | …ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py | 138 | # json_params will not be present in the key_value_params if no scaffold properties | STRING |
| MEDIUM | …ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py | 143 | # default to python for decorator scaffolding. Default is YAML (set by option) for | STRING |
| MEDIUM | …ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py | 174 | # If there are defined scaffold properties, add them to the command. Also only add | STRING |
| MEDIUM | …ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py | 175 | # `--json-params` if there are defined scaffold properties. | STRING |
| MEDIUM | …ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py | 258 | # pull parameters directly off the target command. For these component scaffold subcommands we need | STRING |
| MEDIUM | …dagster-dg-cli/dagster_dg_cli/cli/scaffold/__init__.py | 21 | # Register all scaffold commands from submodules | COMMENT |
| MEDIUM | …er-dg-cli/dagster_dg_cli/cli/scaffold/branch/CLAUDE.md | 30 | ├── best_practices.md # Best practices for scaffolding | CODE |
| MEDIUM | …er-dg-cli/dagster_dg_cli/cli/scaffold/branch/CLAUDE.md | 31 | └── scaffolding_instructions.md # Content scaffolding instructions | CODE |
| MEDIUM | …agster_dg_cli/cli/scaffold/branch/claude/sdk_client.py | 89 | permission_mode="acceptEdits", # Auto-accept file edits for scaffolding | CODE |
| MEDIUM | …cli/plus/deploy/configure/configure_build_artifacts.py | 36 | # For serverless with PEX deploys, skip scaffolding build artifacts | COMMENT |
| MEDIUM | …gster_dg_cli/cli/plus/deploy/configure/configure_ci.py | 324 | # No CI/CD scaffolding requested | COMMENT |
| MEDIUM | …i/dagster_dg_cli/cli/plus/deploy/configure/commands.py | 214 | # Resolve organization, URL, and deployment (only needed if scaffolding CI/CD) | COMMENT |
| MEDIUM | …ries/dagster-dg-core/dagster_dg_core/shared_options.py | 87 | # When set, this will cause project scaffolding to default to --use-editable-dagster mode. | STRING |
| MEDIUM⚡ | …s/libraries/dagster-dg-core/dagster_dg_core/context.py | 486 | # it uses for all component type scaffolding operations. | COMMENT |
| MEDIUM | python_modules/dagster/README.md | 103 | ### Dagster as a robust orchestration engine | COMMENT |
| MEDIUM⚡ | …gster/dagster_tests/cli_tests/test_project_commands.py | 160 | # `dagster project scaffold-code-location` command is deprecated. | COMMENT |
| MEDIUM⚡ | …gster/dagster_tests/cli_tests/test_project_commands.py | 199 | # `dagster project scaffold-repository` command is deprecated. | COMMENT |
| MEDIUM | …agster/_core/definitions/metadata/external_metadata.py | 29 | # Infer the type from the raw value on the orchestration end | COMMENT |
| MEDIUM | …ules/dagster/dagster/components/component/component.py | 188 | dg scaffold defs MyComponent path/to/component # Generate component instance with scaffolding | STRING |
| MEDIUM | …dagster/dagster/components/lib/shim_components/base.py | 13 | # temporary hack as currently all scaffold requests target directories | COMMENT |
| MEDIUM | …odules/dagster/dagster/components/scaffold/scaffold.py | 107 | # target path for the scaffold request. Typically used to construct absolute paths | COMMENT |
| MEDIUM | …odules/dagster/dagster/components/scaffold/scaffold.py | 113 | # optional params for scaffolding | COMMENT |
| MEDIUM | …thon_modules/dagster/dagster/_cli/config_scaffolder.py | 37 | # scaffolding logic, which might not be wise. | COMMENT |
| MEDIUM | python_modules/dagster-pipes/dagster_pipes/__init__.py | 155 | # Infer the type from the raw value on the orchestration end | COMMENT |
| MEDIUM | python_modules/dagster-pipes/dagster_pipes/__init__.py | 1587 | # Keep the close itself so the orchestration side still sees the run end. | COMMENT |
| MEDIUM | …on/dagster_dev/commands/browse_scaffold_branch_logs.py | 30 | # Check if directory contains any scaffold diagnostic files | COMMENT |
| MEDIUM | .claude/python_packages.md | 27 | ## container orchestration | COMMENT |
| MEDIUM | ty/master/pyproject.toml | 409 | # Deliberately-malformed scaffold used as a fixture for notebook-creation tests. | COMMENT |
| MEDIUM⚡ | docs/docs/dagster-basics-tutorial/1-assets.md | 15 | When building assets, the first step is to scaffold an assets file with the [`dg scaffold` command](/api/clis/dg-cli/dg- | CODE |
| MEDIUM | docs/docs/integrations/libraries/dbt/reference.md | 21 | | [`dagster-dbt project scaffold`](/integrations/libraries/dbt/dagster-dbt#scaffold) | CODE |
| MEDIUM | docs/docs/integrations/libraries/dbt/reference.md | 58 | You can create a Dagster project that wraps your dbt project by using the [`dagster-dbt project scaffold`](/integrations | CODE |
| MEDIUM | docs/docs/integrations/libraries/dbt/reference.md | 79 | In the Dagster project created by the [`dagster-dbt project scaffold`](/integrations/libraries/dbt/dagster-dbt#scaffold) | CODE |
| MEDIUM⚡ | …integrations/libraries/dbt/dbt-migration-components.md | 12 | The first step is to [scaffold a dbt component definition](/integrations/libraries/dbt#step-3-scaffold-a-dbt-component-d | CODE |
| MEDIUM | …t-with-dagster-plus/serverless/existing-dbt-project.md | 47 | - Dagster+ will create a new Dagster project in the repository using the [`dagster-dbt scaffold`](/integrations/librarie | CODE |
| MEDIUM | docs/docs/integrations/libraries/soda/index.md | 38 | Use the Dagster CLI to scaffold a new Soda scan component in your project. This requires [dagster-dg-cli](https://docs.d | CODE |
| MEDIUM | …l-pipelines/dagster-pipes-details-and-customization.md | 42 | ### Session lifecycle (orchestration process) | COMMENT |
| MEDIUM | docs/docs/getting-started/quickstart.md | 159 | Use the [`dg scaffold defs`](/api/clis/dg-cli/dg-cli-reference#dg-scaffold) command to generate an assets file on the co | CODE |
| 41 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | pyproject.toml | 101 | asyncio_default_fixture_loop_scope = "session" | COMMENT |
| LOW | …modules/dagster-test/dagster_test/dg_utils/__init__.py | 1 | # Test utilities for dagster-dg packages | COMMENT |
| LOW | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 781 | # below tests. | COMMENT |
| LOW | …aphql/dagster_graphql_tests/graphql/test_composites.py | 21 | # (+4) | COMMENT |
| LOW | …dagster/create_dagster_tests/test_scaffold_commands.py | 101 | # dagster (i.e. from the same commit), and the only way to achieve this right now is | COMMENT |
| LOW | …odules/libraries/dagster-dask/dagster_dask/executor.py | 301 | # if address is set, don't add LocalCluster args | COMMENT |
| LOW | …gster-postgres/dagster_postgres/event_log/event_log.py | 281 | # queries against the event log. | COMMENT |
| LOW | …dagster-airflow/dagster_airflow_tests/airflow_utils.py | 1 | COMPLEX_DAG_FILE_CONTENTS_AIRFLOW_2 = '''# | COMMENT |
| LOW | …dagster-airflow/dagster_airflow_tests/airflow_utils.py | 261 | # | COMMENT |
| LOW | …on_modules/libraries/dagster-dbt/dagster_dbt/compat.py | 121 | # Use this ONLY for refable nodes -- it is not valid for tests. `warn` is a success for a | COMMENT |
| LOW | …_modules/libraries/dagster-dbt/dagster_dbt/__init__.py | 81 | COMMENT | |
| LOW | …les/libraries/dagster-dbt/dagster_dbt/core/resource.py | 661 | # Also, allow it to be overriden by the current environment. | COMMENT |
| LOW | …/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py | 241 | # Fetch information about the job. | COMMENT |
| LOW | …/libraries/dagster-pandera/dagster_pandera/__init__.py | 1 | import itertools | COMMENT |
| LOW | …/libraries/dagster-gcp/dagster_gcp/bigquery/configs.py | 181 | query_parameters = Field( | COMMENT |
| LOW | …n_modules/libraries/dagstermill/dagstermill/factory.py | 201 | # Retry on kernel startup failures caused by ZMQ port collisions. When | COMMENT |
| LOW | …/dagster-ge/dagster_ge_tests/gx/great_expectations.yml | 1 | # Welcome to Great Expectations! Always know what to expect from your data. | COMMENT |
| LOW | …-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py | 121 | # pod_template_spec_metadata: # Metadata for the code server pod | COMMENT |
| LOW | …-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py | 141 | # job_spec_config: # Config for the Kubernetes job for the run | COMMENT |
| LOW | …-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py | 161 | # run_resources: # Resources for runs launched by the agent for this location | COMMENT |
| LOW | …-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py | 181 | # run_sidecar_containers: | COMMENT |
| LOW | …/dagster-aws/dagster_aws_tests/pipes_tests/test_ecs.py | 221 | # dense with sqlalchemy GC callbacks, so a single SIGTERM lands in a | COMMENT |
| LOW | …n_modules/libraries/dagster-aws/dagster_aws/emr/emr.py | 1 | # Portions of this file are copied from the Yelp MRJob project: | COMMENT |
| LOW | …libraries/dagster-aws/dagster_aws/utils/mrjob/log4j.py | 1 | # Copyright 2015-2016 Yelp | COMMENT |
| LOW | …libraries/dagster-aws/dagster_aws/utils/mrjob/retry.py | 1 | # This file duplicated from the Yelp MRJob project: | COMMENT |
| LOW | …libraries/dagster-aws/dagster_aws/utils/mrjob/utils.py | 1 | # This file duplicated from the Yelp MRJob project: | COMMENT |
| LOW | …ibraries/dagster-dg-core/dagster_dg_core/completion.py | 1 | import click | COMMENT |
| LOW | …aries/dagster-shared/dagster_shared/check/functions.py | 21 | Numeric: TypeAlias = int | float | COMMENT |
| LOW | …aries/dagster-shared/dagster_shared/check/functions.py | 41 | # - Parameter checks (`<type>_param`): Used to type-check the arguments to a function, typically | COMMENT |
| LOW | …aries/dagster-shared/dagster_shared/check/functions.py | 621 | # NOTE: inst() and opt_inst() perform narrowing, while inst_param() and opt_inst_param() do not. The | COMMENT |
| LOW | …owflake-pyspark/dagster_snowflake_pyspark/constants.py | 1 | # Description: This file contains the Snowflake connection identifiers for the Snowflake partner account. | COMMENT |
| LOW | …l_tests/compat_tests/test_change_snapshot_structure.py | 41 | # from dagster import solid, DagsterInstance, execute_pipeline | COMMENT |
| LOW | …/dagster/dagster_tests/utils_tests/test_annotations.py | 101 | ) | COMMENT |
| LOW | …les/dagster/dagster_tests/core_tests/test_data_time.py | 21 | @pytest.mark.parametrize( | COMMENT |
| LOW | …/declarative_automation_tests/daemon_tests/test_e2e.py | 621 | COMMENT | |
| LOW | python_modules/dagster/dagster/__init__.py | 1 | import sys | COMMENT |
| LOW | python_modules/dagster/dagster/__init__.py | 21 | # ### dagster/foo/bar.py | COMMENT |
| LOW | python_modules/dagster/dagster/_grpc/server.py | 1561 | # E0625 08:46:56.180112000 4697443776 server_chttp2.cc:40] | COMMENT |
| LOW | …n_modules/dagster/dagster/_core/storage/dagster_run.py | 161 | COMMENT | |
| LOW | …n_modules/dagster/dagster/_core/storage/dagster_run.py | 761 | class RunPartitionData: | COMMENT |
| LOW | …gster/dagster/_core/storage/event_log/sql_event_log.py | 261 | COMMENT | |
| LOW | …gster/dagster/_core/storage/event_log/sql_event_log.py | 1881 | COMMENT | |
| LOW | python_modules/dagster/dagster/_core/execution/api.py | 41 | # | --------------------------- | ------------------ | ----- | ----------- | ----------------------- | | COMMENT |
| LOW | …/dagster/dagster/_core/execution/context/invocation.py | 221 | ) | COMMENT |
| LOW | …ster/dagster/_core/execution/plan/compute_generator.py | 141 | COMMENT | |
| LOW | …hon_modules/dagster/dagster/_core/snap/job_snapshot.py | 61 | def _create_job_snapshot_id(job_snap: "JobSnap"): | COMMENT |
| LOW | python_modules/dagster/dagster/_core/instance/utils.py | 21 | # actually using this constants. | COMMENT |
| LOW | …ules/dagster/dagster/_core/instance/runs/run_domain.py | 161 | COMMENT | |
| LOW | python_modules/dagster/dagster/_core/events/__init__.py | 2201 | file_key=check.str_param(file_key, "file_key"), | COMMENT |
| LOW | python_modules/dagster/dagster/_core/events/__init__.py | 2221 | # | Events | | Operations | | Failures | | COMMENT |
| LOW | …ules/dagster/dagster/_core/definitions/data_version.py | 541 | # never been materialized) | COMMENT |
| LOW | …hon_modules/dagster/dagster/_core/definitions/utils.py | 461 | selection = check.not_none(sensor.asset_selection) | COMMENT |
| LOW | …ster/_core/definitions/assets/definition/asset_spec.py | 41 | from dagster._core.definitions.assets.definition.assets_definition import AssetsDefinition | COMMENT |
| LOW | …ster/_core/definitions/assets/definition/asset_spec.py | 61 | COMMENT | |
| LOW | python_modules/dagster/dagster/_cli/api.py | 361 | step_stats_by_key = get_step_stats_by_key(instance, dagster_run, step_keys_to_execute) | COMMENT |
| LOW | …on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py | 261 | COMMENT | |
| LOW | …on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py | 541 | out.trans_list_utc = [] | COMMENT |
| LOW | …on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py | 561 | # seconds to be added to UTC, tt_isdst tells whether | COMMENT |
| LOW | …on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py | 581 | # by time. | COMMENT |
| LOW | …agster/dagster/_config/pythonic_config/typing_utils.py | 201 | """ | COMMENT |
| 169 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …odules/dagster-test/dagster_test/utils/data_factory.py | 38 | CODE | |
| LOW | …odules/dagster-test/dagster_test/utils/data_factory.py | 60 | CODE | |
| LOW | …odules/dagster-test/dagster_test/utils/data_factory.py | 88 | CODE | |
| LOW | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 361 | CODE | |
| LOW | …on_modules/dagster-test/dagster_test/dg_utils/utils.py | 922 | CODE | |
| LOW | …les/dagster-graphql/dagster_graphql/schema/instance.py | 345 | CODE | |
| LOW | …dules/dagster-graphql/dagster_graphql/client/client.py | 151 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 61 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 256 | CODE | |
| LOW | …ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py | 913 | CODE | |
| LOW | …ster-airbyte/dagster_airbyte/managed/reconciliation.py | 735 | CODE | |
| LOW | …s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py | 587 | CODE | |
| LOW | …s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py | 54 | CODE | |
| LOW | …/dagster-cloud-cli/dagster_cloud_cli/core/workspace.py | 52 | CODE | |
| LOW | …er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py | 401 | CODE | |
| LOW | …er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py | 643 | CODE | |
| LOW | …r-cloud-cli/dagster_cloud_cli/commands/job/__init__.py | 21 | CODE | |
| LOW | …gster_cloud_cli/commands/branch_deployment/__init__.py | 41 | CODE | |
| LOW | …s/libraries/dagster-dlt/dagster_dlt/asset_decorator.py | 57 | CODE | |
| LOW | …agster-azure/dagster_azure/blob/compute_log_manager.py | 118 | CODE | |
| LOW | python_modules/libraries/dagster-k8s/dagster_k8s/job.py | 120 | CODE | |
| LOW | python_modules/libraries/dagster-k8s/dagster_k8s/job.py | 378 | CODE | |
| LOW | …libraries/dagster-k8s/dagster_k8s/container_context.py | 64 | CODE | |
| LOW | …hon_modules/libraries/dagster-k8s/dagster_k8s/pipes.py | 448 | CODE | |
| LOW | …_modules/libraries/dagster-k8s/dagster_k8s/launcher.py | 44 | CODE | |
| LOW | …es/libraries/dagster-k8s/dagster_k8s/ops/k8s_job_op.py | 142 | CODE | |
| LOW | …-airflow/dagster_airflow/operators/dagster_operator.py | 40 | CODE | |
| LOW | …s/libraries/dagster-dbt/dagster_dbt/asset_decorator.py | 30 | CODE | |
| LOW | …dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py | 380 | CODE | |
| LOW | …es/dagster-dbt/dagster_dbt/cloud_v2/asset_decorator.py | 27 | CODE | |
| LOW | …agster-dbt/dagster_dbt_tests/core/test_asset_checks.py | 351 | CODE | |
| LOW | …-airlift/dagster_airlift/test/airflow_test_instance.py | 359 | CODE | |
| LOW | …r-airlift/dagster_airlift_tests/unit_tests/conftest.py | 67 | CODE | |
| LOW | …r-airlift/dagster_airlift_tests/unit_tests/conftest.py | 145 | CODE | |
| LOW | …libraries/dagster-datadog/dagster_datadog/resources.py | 17 | CODE | |
| LOW | …ries/dagster-celery-k8s/dagster_celery_k8s/launcher.py | 63 | CODE | |
| LOW | …ries/dagster-celery-k8s/dagster_celery_k8s/executor.py | 138 | CODE | |
| LOW | …/dagster_rest_resources_tests/api_tests/test_secret.py | 26 | CODE | |
| LOW | …n_modules/libraries/dagstermill/dagstermill/factory.py | 381 | CODE | |
| LOW | …les/libraries/dagstermill/dagstermill/asset_factory.py | 75 | CODE | |
| LOW | …s/libraries/dagster-msteams/dagster_msteams/sensors.py | 43 | CODE | |
| LOW | …dagster_databricks/databricks_pyspark_step_launcher.py | 199 | CODE | |
| LOW | …es/dagster-databricks/dagster_databricks/databricks.py | 249 | CODE | |
| LOW | …es/dagster-databricks/dagster_databricks/databricks.py | 435 | CODE | |
| LOW | …raries/dagster-fivetran/dagster_fivetran/asset_defs.py | 230 | CODE | |
| LOW | …raries/dagster-fivetran/dagster_fivetran/asset_defs.py | 594 | CODE | |
| LOW | …dules/libraries/dagster-slack/dagster_slack/sensors.py | 91 | CODE | |
| LOW | …es/libraries/dagster-aws/dagster_aws/ssm/parameters.py | 10 | CODE | |
| LOW | …ries/dagster-aws/dagster_aws/secretsmanager/secrets.py | 10 | CODE | |
| LOW | …ries/dagster-aws/dagster_aws/s3/compute_log_manager.py | 77 | CODE | |
| LOW | …_modules/libraries/dagster-aws/dagster_aws/s3/utils.py | 25 | CODE | |
| LOW | …modules/libraries/dagster-aws/dagster_aws/ecs/tasks.py | 268 | CODE | |
| LOW | …modules/libraries/dagster-aws/dagster_aws/ecs/tasks.py | 65 | CODE | |
| LOW | …aries/dagster-aws/dagster_aws/ecs/container_context.py | 256 | CODE | |
| LOW | …ules/libraries/dagster-aws/dagster_aws/ecs/launcher.py | 114 | CODE | |
| LOW | …braries/dagster-shared/dagster_shared/serdes/serdes.py | 245 | CODE | |
| LOW | …braries/dagster-shared/dagster_shared/serdes/serdes.py | 260 | CODE | |
| LOW | …braries/dagster-shared/dagster_shared/serdes/serdes.py | 356 | CODE | |
| LOW | …braries/dagster-shared/dagster_shared/serdes/serdes.py | 153 | CODE | |
| LOW | …ies/dagster-polytomic/dagster_polytomic_tests/utils.py | 28 | CODE | |
| 144 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL⚡ | …ster_azure_tests/container_apps_tests/test_launcher.py | 314 | client.jobs.begin_create_or_update.return_value.result.assert_called_once_with( | CODE |
| CRITICAL⚡ | …ster_azure_tests/container_apps_tests/test_launcher.py | 318 | client.jobs.begin_start.return_value.result.assert_not_called() | CODE |
| CRITICAL | …es/libraries/dagster-azure/dagster_azure/blob/utils.py | 7 | from azure.core.exceptions import ResourceNotFoundError | CODE |
| CRITICAL | …s/libraries/dagster-azure/dagster_azure/adls2/utils.py | 7 | from azure.core.exceptions import ResourceNotFoundError | CODE |
| CRITICAL | …braries/dagster-ge/dagster_ge_tests/test_validation.py | 56 | context.resources.pyspark.spark_session.read.format("csv") | CODE |
| CRITICAL | …dagster_databricks/databricks_pyspark_step_launcher.py | 298 | self.databricks_runner.client.workspace_client.jobs.cancel_run(databricks_run_id) | CODE |
| CRITICAL⚡ | …dagster_databricks/databricks_pyspark_step_launcher.py | 336 | run = self.databricks_runner.client.workspace_client.jobs.get_run( | CODE |
| CRITICAL | …gster_cloud_tests/workspace_tests/test_aca_launcher.py | 11 | from azure.core.exceptions import HttpResponseError | CODE |
| CRITICAL | …gster_cloud_tests/workspace_tests/test_aca_launcher.py | 329 | client.container_apps.begin_create_or_update.return_value.result.assert_called_once_with( | CODE |
| CRITICAL | …/dagster-cloud/dagster_cloud/workspace/aca/launcher.py | 33 | from azure.core.exceptions import AzureError | CODE |
| CRITICAL | …/dagster-k8s-test-infra/dagster_k8s_test_infra/helm.py | 575 | assert target.spec.template.metadata.labels.get(key) == labels.get( | CODE |
| CRITICAL | …re/src/runs/__tests__/useCursorPaginatedQuery.test.tsx | 86 | act(() => view.result.current.feed.paginationProps.advanceCursor()); | CODE |
| CRITICAL | …re/src/runs/__tests__/useCursorPaginatedQuery.test.tsx | 89 | act(() => view.result.current.feed.paginationProps.advanceCursor()); | CODE |
| CRITICAL | …re/src/runs/__tests__/useCursorPaginatedQuery.test.tsx | 215 | act(() => remounted.result.current.feed.paginationProps.popCursor()); | CODE |
| CRITICAL | helm/dagster/schema/schema_tests/test_dagit.py | 347 | assert set(pod_labels.items()).issubset(deployment.spec.template.metadata.labels.items()) | CODE |
| CRITICAL | helm/dagster/schema/schema_tests/test_dagster_daemon.py | 510 | assert set(pod_labels.items()).issubset(daemon_deployment.spec.template.metadata.labels.items()) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/dagster-github/dagster_github_tests/test_resources.py | 94 | "token": "fake_token", | CODE |
| LOW | …/dagster-github/dagster_github_tests/test_resources.py | 144 | "token": "fake_token", | CODE |
| LOW | …/dagster-github/dagster_github_tests/test_resources.py | 196 | "token": "fake_token", | CODE |
| LOW | …/dagster-github/dagster_github_tests/test_resources.py | 266 | "token": "fake_token", | CODE |
| LOW | …/dagster-github/dagster_github_tests/test_resources.py | 332 | "token": "fake_token", | CODE |
| LOW | …/dagster-github/dagster_github_tests/test_resources.py | 367 | "token": "fake_token", | CODE |
| LOW | …ster-cloud-cli/dagster_cloud_cli_tests/test_metrics.py | 86 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …ster-cloud-cli/dagster_cloud_cli_tests/test_metrics.py | 194 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 64 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "some-org:fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 141 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "some-org:fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 330 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 409 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 481 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 526 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 557 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 588 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | STRING |
| LOW | …-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py | 706 | monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token") | CODE |
| LOW⚡ | …sts/commands/integration/test_atlan_integration_cli.py | 6 | FAKE_TOKEN = "fake_token" | CODE |
| LOW⚡ | …sts/commands/integration/test_atlan_integration_cli.py | 18 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 54 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 77 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 119 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 154 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 180 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 213 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 236 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 275 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 297 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 324 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …sts/commands/integration/test_atlan_integration_cli.py | 354 | "DAGSTER_CLOUD_API_TOKEN": "fake-token", | CODE |
| LOW | …talake/dagster_deltalake_tests/test_metadata_inputs.py | 19 | metadata={"schema": "a_df", "mode": "append", "custom_metadata": {"userName": "John Doe"}} | CODE |
| LOW⚡ | …talake/dagster_deltalake_tests/test_metadata_inputs.py | 44 | assert last_action["userName"] == "John Doe" | CODE |
| LOW⚡ | …talake/dagster_deltalake_tests/test_metadata_inputs.py | 57 | custom_metadata={"userName": "John Doe"}, | CODE |
| LOW | …talake/dagster_deltalake_tests/test_metadata_inputs.py | 83 | assert last_action["userName"] == "John Doe" | CODE |
| LOW⚡ | …agster_azure_tests/adls2_tests/test_endpoint_suffix.py | 67 | credential=ADLS2SASToken(token="fake-token"), | CODE |
| LOW⚡ | …agster_azure_tests/adls2_tests/test_endpoint_suffix.py | 70 | mock_create.assert_called_once_with("myaccount", "fake-token", "core.windows.net") | CODE |
| LOW⚡ | …agster_azure_tests/adls2_tests/test_endpoint_suffix.py | 76 | credential=ADLS2SASToken(token="fake-token"), | CODE |
| LOW⚡ | …agster_azure_tests/adls2_tests/test_endpoint_suffix.py | 80 | mock_create.assert_called_once_with("myaccount", "fake-token", "core.usgovcloudapi.net") | CODE |
| LOW⚡ | …agster_azure_tests/adls2_tests/test_endpoint_suffix.py | 86 | credential=ADLS2SASToken(token="fake-token"), | CODE |
| LOW⚡ | …agster_azure_tests/adls2_tests/test_endpoint_suffix.py | 90 | mock_create.assert_called_once_with("myaccount", "fake-token", "core.usgovcloudapi.net") | CODE |
| LOW | …agster_azure_tests/components_tests/test_components.py | 57 | monkeypatch.setenv("AZURE_STORAGE_KEY", "fake-key") | CODE |
| LOW⚡ | …s/dagster-postgres/dagster_postgres_tests/test_auth.py | 27 | def __init__(self, token: str = "fake-token", ttl: float = 3600) -> None: | CODE |
| LOW | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 166 | tags={REPOSITORY_LABEL_TAG: "placeholder"}, | CODE |
| LOW | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 286 | tags={REPOSITORY_LABEL_TAG: "placeholder"}, | CODE |
| LOW | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 370 | tags={REPOSITORY_LABEL_TAG: "placeholder"}, | CODE |
| LOW | …ift_tests/unit_tests/core_tests/test_monitoring_job.py | 514 | tags={REPOSITORY_LABEL_TAG: "placeholder"}, | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 34 | fake_token = uuid.uuid4().hex | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 36 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 50 | fake_token = uuid.uuid4().hex | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 52 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 64 | fake_token = uuid.uuid4().hex | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 66 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 96 | fake_token = uuid.uuid4().hex | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 98 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 151 | fake_token = uuid.uuid4().hex | CODE |
| LOW⚡ | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 153 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| LOW | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 212 | fake_token = uuid.uuid4().hex | CODE |
| LOW | …ster-powerbi/dagster_powerbi_tests/test_asset_specs.py | 214 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| LOW⚡ | …dagster-powerbi/dagster_powerbi_tests/test_resource.py | 15 | fake_token = uuid.uuid4().hex | CODE |
| LOW⚡ | …dagster-powerbi/dagster_powerbi_tests/test_resource.py | 18 | credentials=PowerBIToken(api_token=fake_token), | CODE |
| 89 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …es/libraries/dagster-github/dagster_github/__init__.py | 8 | __all__ = ["GithubResource", "github_resource"] | CODE |
| LOW | …ter-snowflake/dagster_snowflake/components/__init__.py | 5 | __all__ = [ | CODE |
| LOW | …ries/dagster-prometheus/dagster_prometheus/__init__.py | 8 | __all__ = ["PrometheusResource", "prometheus_resource"] | CODE |
| LOW | …_modules/libraries/dagster-dlt/dagster_dlt/__init__.py | 9 | __all__ = [ | CODE |
| LOW | …dagster-azure/dagster_azure/container_apps/launcher.py | 55 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ibraries/dagster-azure/dagster_azure/pipes/__init__.py | 5 | __all__ = [ | CODE |
| LOW | …/dagster-azure/dagster_azure/pipes/clients/__init__.py | 3 | __all__ = [ | CODE |
| LOW | …es/libraries/dagster-azure/dagster_azure/blob/utils.py | 41 | __all__ = [ | CODE |
| LOW | …s/libraries/dagster-azure/dagster_azure/adls2/utils.py | 39 | __all__ = [ | CODE |
| LOW | …es/libraries/dagster-postgres/dagster_postgres/auth.py | 10 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ibraries/dagster-postgres/dagster_postgres/__init__.py | 10 | __all__ = [ | CODE |
| LOW | …r-postgres/dagster_postgres/run_storage/run_storage.py | 214 | def set_cursor_values(self, pairs: Mapping[str, str]) -> None: | CODE |
| LOW | …on_modules/libraries/dagster-k8s/dagster_k8s/client.py | 28 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ries/dagster-papertrail/dagster_papertrail/__init__.py | 8 | __all__ = ["papertrail_logger"] | CODE |
| LOW | …es/libraries/dagster-celery/dagster_celery/__init__.py | 8 | __all__ = ["celery_executor"] | CODE |
| LOW | …/libraries/dagster-airflow/dagster_airflow/__init__.py | 30 | __all__ = [ | CODE |
| LOW | …/dagster-airflow/dagster_airflow/resources/__init__.py | 8 | __all__ = ["make_ephemeral_airflow_db_resource", "make_persistent_airflow_db_resource"] | CODE |
| LOW | …dagster-dbt/dagster_dbt/cloud_v2/component/__init__.py | 5 | __all__ = ["DbtCloudComponent"] | CODE |
| LOW | …ies/dagster-dbt/dagster_dbt_tests/cloud_v2/conftest.py | 1005 | def _set_init_load_context() -> None: | CODE |
| LOW | …-sink/dagster_dbt_cloud_kitchen_sink_tests/conftest.py | 18 | logger = logging.getLogger(__name__) | CODE |
| LOW | …kitchen-sink/dagster_dbt_cloud_kitchen_sink/cleanup.py | 13 | logger = logging.getLogger(__name__) | CODE |
| LOW | …es/libraries/dagster-census/dagster_census/__init__.py | 11 | __all__ = [ | CODE |
| LOW | …odules/libraries/dagster-soda/dagster_soda/__init__.py | 6 | __all__ = [ | CODE |
| LOW | …lift/dagster_airlift/in_airflow/base_asset_operator.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | …r-airlift/dagster_airlift_tests/unit_tests/conftest.py | 219 | def _set_init_load_context() -> None: | CODE |
| LOW | …/libraries/dagster-pandera/dagster_pandera/__init__.py | 323 | __all__ = [ | CODE |
| LOW | …/libraries/dagster-datadog/dagster_datadog/__init__.py | 8 | __all__ = ["DatadogResource", "datadog_resource"] | CODE |
| LOW | …es/libraries/dagster-pandas/dagster_pandas/__init__.py | 30 | __all__ = [ | CODE |
| LOW | …ter-rest-resources/dagster_rest_resources/api/asset.py | 41 | logger = logging.getLogger(__name__) | CODE |
| LOW | …es/libraries/dagster-twilio/dagster_twilio/__init__.py | 11 | __all__ = ["twilio_resource"] | CODE |
| LOW | …es/libraries/dagster-gcp/dagster_gcp/pipes/__init__.py | 5 | __all__ = [ | CODE |
| LOW | …ries/dagster-gcp/dagster_gcp/pipes/clients/__init__.py | 3 | __all__ = ["PipesDataprocJobClient"] | CODE |
| LOW | …braries/dagster-gcp/dagster_gcp/components/__init__.py | 5 | __all__ = [ | CODE |
| LOW | …on_modules/libraries/dagster-ge/dagster_ge/__init__.py | 8 | __all__ = ["ge_validation_op_factory"] | CODE |
| LOW | …/libraries/dagster-pyspark/dagster_pyspark/__init__.py | 14 | __all__ = [ | CODE |
| LOW | …_modules/libraries/dagster-ssh/dagster_ssh/__init__.py | 8 | __all__ = ["SSHResource", "ssh_resource"] | CODE |
| LOW | …modules/libraries/dagster-ssh/dagster_ssh/resources.py | 129 | def set_logger(self, logger: logging.Logger) -> None: | CODE |
| LOW | …use-polars/dagster_clickhouse_polars_tests/conftest.py | 17 | __all__ = ["clickhouse_connection"] | CODE |
| LOW | …lickhouse-polars/dagster_clickhouse_polars/__init__.py | 12 | __all__ = [ | CODE |
| LOW | …ules/libraries/dagster-mysql/dagster_mysql/__init__.py | 10 | __all__ = ["DagsterMySQLStorage", "MySQLEventLogStorage", "MySQLRunStorage", "MySQLScheduleStorage"] | CODE |
| LOW | …dagster-mysql/dagster_mysql/run_storage/run_storage.py | 179 | def set_cursor_values(self, pairs: Mapping[str, str]) -> None: | CODE |
| LOW | …/libraries/dagster-datahub/dagster_datahub/__init__.py | 14 | __all__ = [ | CODE |
| LOW | …ules/libraries/dagster-sling/dagster_sling/__init__.py | 13 | __all__ = [ | CODE |
| LOW | …use-pandas/dagster_clickhouse_pandas_tests/conftest.py | 17 | __all__ = ["clickhouse_connection"] | CODE |
| LOW | …lickhouse-pandas/dagster_clickhouse_pandas/__init__.py | 12 | __all__ = [ | CODE |
| LOW | …dg-cli/dagster_dg_cli/utils/plus/defs_state_storage.py | 165 | def set_latest_version(self, key: str, version: str | None) -> None: | STRING |
| LOW | …ries/dagster-dg-cli/dagster_dg_cli/cli/api/__init__.py | 5 | __all__ = ["api_group"] | CODE |
| LOW | …agster_dg_cli/cli/scaffold/branch/claude/sdk_client.py | 148 | def _update_usage_stats(self, messages: list[Message]) -> None: | CODE |
| LOW | …es/libraries/dagster-aws/dagster_aws/pipes/__init__.py | 21 | __all__ = [ | CODE |
| LOW | …ries/dagster-aws/dagster_aws/pipes/clients/__init__.py | 8 | __all__ = [ | CODE |
| LOW | …raries/dagster-hightouch/dagster_hightouch/__init__.py | 10 | __all__ = [ | CODE |
| LOW | …agster-clickhouse/dagster_clickhouse_tests/conftest.py | 5 | __all__ = ["clickhouse_connection"] | CODE |
| LOW | …ries/dagster-clickhouse/dagster_clickhouse/__init__.py | 17 | __all__ = [ | CODE |
| LOW | …r-clickhouse/dagster_clickhouse/components/__init__.py | 3 | __all__ = [ | CODE |
| LOW | …agster_clickhouse/components/sql_component/__init__.py | 3 | __all__ = [ | CODE |
| LOW⚡ | …es/libraries/dagster-dg-core/dagster_dg_core/config.py | 183 | def set_config_on_cli_context(cli_context: click.Context, config: "DgRawCliConfig") -> None: | CODE |
| LOW | …ries/dagster-dg-core/dagster_dg_core/utils/__init__.py | 219 | def set_option_help_output_group(param: click.Parameter, group: str) -> None: | CODE |
| LOW | …ries/dagster-dg-core/dagster_dg_core/utils/__init__.py | 568 | def set_toml_node(doc: TomlDoc, path: TomlPath, value: object) -> None: | CODE |
| LOW | …es/libraries/dagster-mlflow/dagster_mlflow/__init__.py | 9 | __all__ = ["end_mlflow_on_run_finished", "mlflow_tracking"] | CODE |
| LOW | …s/libraries/dagster-shared/dagster_shared/seven/abc.py | 20 | __all__ = [ | CODE |
| 91 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …l/dagster_graphql/implementation/fetch_asset_checks.py | 171 | # Check if we have any subsets to determine the type | COMMENT |
| LOW⚡ | …l_tests/client_tests/test_submit_pipeline_execution.py | 70 | # Check if the op_selection argument is properly passed to the GraphQL query | COMMENT |
| LOW⚡ | …l_tests/client_tests/test_submit_pipeline_execution.py | 86 | # Check if the asset_selection argument is properly passed to the GraphQL query | COMMENT |
| LOW | …ibraries/dagster-dask/dagster_dask_tests/test_utils.py | 87 | # Set index to ID. We expect the column to be dropped by default. | COMMENT |
| LOW | …ibraries/dagster-dask/dagster_dask_tests/test_utils.py | 95 | # Set index to ID without dropping the column. | COMMENT |
| LOW | …on_modules/libraries/dagster-k8s/dagster_k8s/client.py | 156 | # Check if the status code is generally whitelisted | COMMENT |
| LOW | …on_modules/libraries/dagster-k8s/dagster_k8s/client.py | 211 | # Check if the status code is generally whitelisted | COMMENT |
| LOW | …es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh | 259 | # Check if aliases need to be updated | COMMENT |
| LOW | …es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh | 382 | # Check if already installed and get version | COMMENT |
| LOW | …es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh | 412 | # Check if URL exists and returns valid content | COMMENT |
| LOW | …es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh | 424 | # Check if any files were extracted | COMMENT |
| LOW | …es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh | 472 | # Check if versions match | COMMENT |
| LOW | …libraries/dagster-airlift/dagster_airlift/mwaa/auth.py | 25 | # Check if login was succesfull | COMMENT |
| LOW | …unit_tests/in_airflow_tests/test_no_dagster_install.py | 13 | # Check if uv is installed | COMMENT |
| LOW | …agster-airlift/scripts/find_and_replace_in_yaml_dir.sh | 3 | # Check if all required arguments are provided | COMMENT |
| LOW | …agster-airlift/scripts/find_and_replace_in_yaml_dir.sh | 13 | # Check if the directory exists | COMMENT |
| LOW | …les/libraries/dagster-airlift/scripts/airflow_setup.sh | 3 | # Check if the required arguments are provided | COMMENT |
| LOW | …ies/dagster-gcp/dagster_gcp/gcs/compute_log_manager.py | 86 | # Check if the bucket exists | COMMENT |
| LOW | …r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py | 217 | # Set cursor to sync A's timestamp (orchestration already handled it) | COMMENT |
| LOW | …dagster-fivetran/dagster_fivetran_tests/test_sensor.py | 225 | # Set cursor to the current succeeded_at so there's no "new" sync | COMMENT |
| LOW | …dules/libraries/dagster-omni/dagster_omni/workspace.py | 141 | # Check if we've received fewer users than requested, indicating we're done | COMMENT |
| LOW | …dg-cli/dagster_dg_cli/utils/yaml_template_generator.py | 249 | # Check if any anyOf option is a complex object that should be expanded (existing logic) | COMMENT |
| LOW | …s/libraries/dagster-dg-cli/dagster_dg_cli/cli/utils.py | 525 | # Check if DAGSTER_HOME is set before proceeding | COMMENT |
| LOW | …raries/dagster-dg-cli/dagster_dg_cli/cli/api/client.py | 49 | # Check if we have a test context with custom factory | COMMENT |
| LOW | …raries/dagster-dg-cli/dagster_dg_cli/cli/api/shared.py | 42 | # Check if we're in a test context | COMMENT |
| LOW | …r-dg-cli/dagster_dg_cli/cli/scaffold/branch/command.py | 194 | # Check if we're in a git repository before proceeding | COMMENT |
| LOW | …r-dg-cli/dagster_dg_cli/cli/scaffold/branch/command.py | 223 | # Check if Claude Code SDK and api key are available before proceeding with AI operations | COMMENT |
| LOW | …s/libraries/dagster-mlflow/dagster_mlflow/resources.py | 143 | # Check if a run with this dagster run id has already been started | COMMENT |
| LOW | …ableau/dagster_tableau/components/tableau_component.py | 184 | # Check if workbook's project matches by ID or name | COMMENT |
| LOW | …aries/dagster-shared/dagster_shared/record/__init__.py | 284 | # Add items to lists using replace() | STRING |
| LOW | …aries/dagster-shared/dagster_shared/record/__init__.py | 471 | # Add items to lists (use spread operator to avoid mutation) | STRING |
| LOW | …ies/dagster-shared/dagster_shared/plus/config_utils.py | 142 | # Check if we're in test mode with DgApiTestContext | COMMENT |
| LOW | …ponents/spark_declarative_pipeline/test_integration.py | 10 | # Check if the spark-pipelines CLI is available on the system. | COMMENT |
| LOW | …agster_tests/cli_tests/command_tests/test_telemetry.py | 737 | # Set DAGSTER_HOME to a different directory | COMMENT |
| LOW⚡ | …modules/dagster/dagster_tests/utils_tests/test_path.py | 15 | # Check if uv is installed | COMMENT |
| LOW | …/dagster/dagster_tests/asset_defs_tests/test_assets.py | 2856 | # Check if asset_resource is included in regular_asset's required_resource_keys | COMMENT |
| LOW | …/dagster/dagster_tests/asset_defs_tests/test_assets.py | 2859 | # Check if op_resource is included in complex_graph_asset's required_resource_keys | COMMENT |
| LOW | python_modules/dagster/dagster/_utils/schedules.py | 979 | # Check if this is a DST ambiguous time scenario where both ticks | COMMENT |
| LOW | …/dagster/_core/storage/asset_check_execution_record.py | 158 | # Check if the run is still active, and if not, return the actual status. | COMMENT |
| LOW | …ules/dagster/dagster/components/utils/project_paths.py | 41 | # Check if it's a nested config (pyproject.toml) or root (dg.toml) | COMMENT |
| LOW | …_modules/dagster/dagster/components/resolved/scopes.py | 61 | # Check if this attribute is whitelisted | COMMENT |
| LOW | …on_modules/dagster/dagster/_vendored/dateutil/rrule.py | 850 | # Output results | COMMENT |
| LOW | …s/dagster/dagster/_vendored/dateutil/parser/_parser.py | 731 | # Check if it's a number | COMMENT |
| LOW | …agster/dagster/_config/pythonic_config/typing_utils.py | 136 | # Check if the annotation is a ResourceDependency | COMMENT |
| LOW | …dagster-cloud/dagster_cloud/pex/grpc/server/manager.py | 242 | # Set working_directory to "." if it is not set, so that it does not | COMMENT |
| LOW | …loud/dagster_cloud/workspace/config_schema/__init__.py | 51 | # Check if using the legacy format, see below for details | COMMENT |
| LOW | …ts/dagster_docs_tests/test_discover_section_headers.py | 57 | # Print results | COMMENT |
| LOW | …odules/automation/automation/dagster_docs/validator.py | 287 | # Check if the function has a docstring | COMMENT |
| LOW | …odules/automation/automation/dagster_docs/validator.py | 391 | # Check if this symbol is a top-level exported class with @public annotation | COMMENT |
| LOW | …s/automation/automation/dagster_docs/file_discovery.py | 123 | # Check if file matches any exclude pattern | COMMENT |
| LOW | …utomation/automation/dagster_docs/changed_validator.py | 85 | # Check if the object was defined in this module | COMMENT |
| LOW⚡ | …mation/automation/dagster_docs/public_api_validator.py | 189 | # Check if the node is directly in the module body | COMMENT |
| LOW⚡ | …mation/automation/dagster_docs/public_api_validator.py | 202 | # Check if it's exported from main dagster module | COMMENT |
| LOW⚡ | …mation/automation/dagster_docs/public_api_validator.py | 205 | # Check if it's exported from the library's top-level | COMMENT |
| LOW | …mation/automation/dagster_docs/public_api_validator.py | 156 | # Check if this symbol is exported at top-level | COMMENT |
| LOW | …mation/automation/dagster_docs/public_api_validator.py | 223 | # Check if it's exported from main dagster module | COMMENT |
| LOW | …mation/automation/dagster_docs/public_api_validator.py | 229 | # Check if it's exported from a library top-level | COMMENT |
| LOW | …mation/automation/dagster_docs/public_api_validator.py | 382 | # Check if @public symbol has RST documentation | COMMENT |
| LOW | …mation/automation/dagster_docs/public_api_validator.py | 393 | # Check if @public symbol is exported at top-level | COMMENT |
| LOW | …mation/automation/dagster_docs/public_api_validator.py | 434 | # Check if RST documented symbol has @public decorator | COMMENT |
| 39 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/dagster_snowflake/components/dbt_project/component.py | 1278 | # robust, first-class analog of dbt Cloud filtering out its adhoc-job runs. | COMMENT |
| LOW | …ster-cloud-cli/dagster_cloud_cli_tests/test_metrics.py | 211 | # For tests, just pass the word "foo" to | COMMENT |
| MEDIUM | …braries/dagster-deltalake/dagster_deltalake/handler.py | 105 | # TODO make robust and move to function | COMMENT |
| LOW | …braries/dagster-azure/dagster_azure/adls2/resources.py | 180 | # config fields in the new resource config. Instead, we'll just use the old config fields | COMMENT |
| MEDIUM | …s/dagster-celery/dagster_celery/core_execution_loop.py | 95 | # Certainly yield an engine or job event | COMMENT |
| LOW | …/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py | 193 | # Since we're only doing this to generate the dependency structure, just use an arbitrary | COMMENT |
| LOW | …/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py | 212 | # However, we can't just use the dependency structure from the latest run, because | COMMENT |
| LOW | …/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py | 474 | # so we cannot just add our arg as last one to be used and need to remove | COMMENT |
| LOW | …s/libraries/dagster-dbt/dagster_dbt/cloud/resources.py | 207 | # API requires you to supply a bunch of values, so we can just use the current state | COMMENT |
| MEDIUM | python_modules/libraries/dagster-airlift/pyproject.toml | 57 | # airlift example/tutorial ecosystem (kitchen-sink, perf-harness, | COMMENT |
| LOW⚡ | …aries/dagster-gcp/dagster_gcp/pipes/message_readers.py | 132 | # just call head object on f"{key_prefix}/1.json" (no need to download it) | COMMENT |
| LOW | …n_modules/libraries/dagstermill/dagstermill/factory.py | 80 | # papermill method chooses translator based on kernel_name and language, but we just call the | COMMENT |
| MEDIUM | …ster-databricks/dagster_databricks_tests/test_pipes.py | 39 | # To facilitate using the same script for testing in both the new cluster and existing cluster | COMMENT |
| MEDIUM | …gster_dg_cli_tests/cli_tests/test_scaffold_commands.py | 99 | # Get pydantic version to make test robust across versions | COMMENT |
| MEDIUM | …gster_dg_cli/cli/scaffold/branch/claude/diagnostics.py | 242 | """Context manager for Claude operations that handles timing and comprehensive logging. | STRING |
| LOW | …gster_dg_cli/cli/plus/deploy/configure/configure_ci.py | 37 | # TODO: when we cut over to dg deploy, we'll just use a single build call for the workspace | COMMENT |
| MEDIUM | …libraries/dagster-aws/dagster_aws/emr/configs_spark.py | 543 | description="""Execution Behavior: If set to true (default), file fetching w | CODE |
| MEDIUM | …libraries/dagster-aws/dagster_aws/emr/configs_spark.py | 726 | description="""Shuffle Behavior: (Netty only) Connections betwee | CODE |
| MEDIUM | …libraries/dagster-aws/dagster_aws/emr/configs_spark.py | 762 | description="""Shuffle Behavior: Enables the external shuffle se | CODE |
| MEDIUM | …libraries/dagster-aws/dagster_aws/emr/configs_spark.py | 1794 | description="""Execution Behavior: If set to true, clones a new Hadoop Confi | CODE |
| MEDIUM | …libraries/dagster-aws/dagster_aws/emr/configs_spark.py | 2303 | description="""Scheduling: Amount of a particular re | CODE |
| MEDIUM | …braries/dagster-shared/dagster_shared/serdes/serdes.py | 1106 | # the object_handler for _transform_for_serialization to use in conjunction with json.dumps for iterative serializat | COMMENT |
| MEDIUM | …libraries/dagster-spark/dagster_spark/configs_spark.py | 543 | description="""Execution Behavior: If set to true (default), file fetching w | CODE |
| MEDIUM | …libraries/dagster-spark/dagster_spark/configs_spark.py | 726 | description="""Shuffle Behavior: (Netty only) Connections betwee | CODE |
| MEDIUM | …libraries/dagster-spark/dagster_spark/configs_spark.py | 762 | description="""Shuffle Behavior: Enables the external shuffle se | CODE |
| MEDIUM | …libraries/dagster-spark/dagster_spark/configs_spark.py | 1794 | description="""Execution Behavior: If set to true, clones a new Hadoop Confi | CODE |
| MEDIUM | …libraries/dagster-spark/dagster_spark/configs_spark.py | 2303 | description="""Scheduling: Amount of a particular re | CODE |
| LOW | …tion_tests/misc_execution_tests/test_asset_backfill.py | 336 | # Patch the run execution to not actually execute the run, but instead just create it | COMMENT |
| MEDIUM | …sts/definitions_tests/test_definitions_load_context.py | 205 | # no harness-reported name -> None | COMMENT |
| LOW | …_defs_tests/asset_graph_view_tests/test_asset_slice.py | 85 | # if asset is removed, don't error just return None | COMMENT |
| MEDIUM | …tests/core_tests/resource_tests/test_with_resources.py | 209 | # because io manager def can utilize default. | COMMENT |
| LOW | …rce_tests/pythonic_resources/test_direct_invocation.py | 185 | # Here we can just use args for x and y because we're providing the resource explicitly as an arg | COMMENT |
| LOW | …e_tests/instance_tests/test_state_storage_lifecycle.py | 152 | # should just set the value to None instead of erroring | COMMENT |
| LOW | …les/dagster/dagster/_utils/caching_instance_queryer.py | 276 | # in the simple case, just use the asset record | COMMENT |
| LOW | …les/dagster/dagster/_utils/caching_instance_queryer.py | 453 | # then, if the before_cursor is after our latest record's storage id, we can just return | COMMENT |
| LOW | …dules/dagster/dagster/_core/storage/defs_state/base.py | 33 | # can't reset the token value, so we just set it to None | COMMENT |
| MEDIUM | …agster/dagster/_core/execution/context_creation_job.py | 59 | # Essentially, we want to be able to control the timestamp of the log records. | COMMENT |
| LOW | …odules/dagster/dagster/_core/execution/plan/objects.py | 120 | # For a redacted error, just return the redacted message without any | COMMENT |
| LOW | …agster/dagster/_core/instance/methods/asset_methods.py | 425 | # materializable asset and should just return that. If not, we should check for any | COMMENT |
| MEDIUM | …gster/dagster/_core/executor/child_process_executor.py | 46 | """Inherit from this class in order to use this library. | STRING |
| LOW | …core/definitions/automation_tick_evaluation_context.py | 552 | # just use the normal single-partition behavior | COMMENT |
| LOW | …/_core/definitions/freshness_based_auto_materialize.py | 135 | # if asset will not be materialized, just return the current time | COMMENT |
| MEDIUM | …/_core/definitions/freshness_based_auto_materialize.py | 166 | """Returns a set of AssetKeyPartitionKeys to materialize in order to abide by the given | STRING |
| LOW | …gster/_core/definitions/auto_materialize_rule_impls.py | 126 | # if all_partitions is set, then just return all partitions if any ticks have been missed | COMMENT |
| LOW | …gster/_core/definitions/auto_materialize_rule_impls.py | 133 | # for partitions_defs without a time component, just return the last partition if any ticks | COMMENT |
| MEDIUM | …gster/dagster/_core/definitions/asset_daemon_cursor.py | 175 | """This serves as a backcompat layer for deserializing the old cursor format. Will only recover | STRING |
| LOW | …efinitions/declarative_automation/operands/operands.py | 211 | # if it's the first time evaluating, just return the empty subset | COMMENT |
| LOW | …efinitions/declarative_automation/operands/operands.py | 275 | # if it's the first time evaluating, just return the empty subset | COMMENT |
| LOW | …er/_core/definitions/partitions/mapping/time_window.py | 326 | # we can just use these boundaries directly instead of finding nearby boundaries. | COMMENT |
| LOW | …ster/_core/definitions/partitions/utils/time_window.py | 142 | # Case where the two don't intersect at all - just return self | COMMENT |
| LOW | …nitions/partitions/definition/partitions_definition.py | 115 | # in the simple case, simply return the single key in the range | COMMENT |
| LOW | …ster/dagster/_core/definitions/partitions/snap/snap.py | 131 | # can't just use a set because we need to preserve ordering.) | COMMENT |
| MEDIUM | …nitions/repository_definition/repository_definition.py | 58 | # the name of the code location being loaded, as reported by the loading harness | COMMENT |
| MEDIUM | …r/_daemon/auto_run_reexecution/auto_run_reexecution.py | 32 | """A more robust method of determining is a run should be retried by the daemon than just looking | STRING |
| MEDIUM | …ules/dagster/dagster/components/core/component_tree.py | 109 | # for app-managed component discovery when the loading harness does not report the | COMMENT |
| LOW | …on_modules/dagster/dagster/_vendored/dateutil/rrule.py | 454 | # been supplied (the string retrieval will just use .get()) | COMMENT |
| MEDIUM | python_modules/dagster/dagster/_config/config_type.py | 91 | """Implement this in order to take a value provided by the user | STRING |
| MEDIUM | …es/dagster/dagster/_config/pythonic_config/resource.py | 173 | """Base class for creating and managing the lifecycle of Dagster resources that utilize structured config. | STRING |
| MEDIUM | …es/dagster/dagster/_config/pythonic_config/resource.py | 598 | """Base class for Dagster resources that utilize structured config. | STRING |
| LOW | …er/dagster/_config/pythonic_config/conversion_utils.py | 185 | # no FloatSource, so we just return float | COMMENT |
| 12 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 14 | # Step 1: Get presigned POST URL | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 23 | # Step 2: Upload file to S3 via presigned POST | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 33 | # Step 1: Get presigned GET URL | COMMENT |
| LOW⚡ | …ter-rest-resources/dagster_rest_resources/s3_client.py | 42 | # Step 2: Download file from S3 | COMMENT |
| LOW⚡ | …libraries/dagster-omni/dagster_omni_tests/test_defs.py | 240 | # Step 1: Fetch workspace data from "API" | COMMENT |
| LOW⚡ | …libraries/dagster-omni/dagster_omni_tests/test_defs.py | 246 | # Step 2: Build definitions from workspace data | COMMENT |
| LOW⚡ | …dagster-polytomic/dagster_polytomic_tests/test_defs.py | 279 | # Step 1: Fetch workspace data from "API" | COMMENT |
| LOW⚡ | …dagster-polytomic/dagster_polytomic_tests/test_defs.py | 282 | # Step 2: Build definitions from workspace data | COMMENT |
| LOW | …_backed_component_tests/test_state_backed_component.py | 425 | # Step 1: Start with versioned storage, no state available | COMMENT |
| LOW⚡ | …_backed_component_tests/test_state_backed_component.py | 449 | # Step 2: Run the update state job to populate versioned storage | COMMENT |
| LOW⚡ | …_backed_component_tests/test_state_backed_component.py | 453 | # Step 3: Reload with versioned storage - should have updated value | COMMENT |
| LOW | …_backed_component_tests/test_state_backed_component.py | 464 | # Step 4: Switch to local storage - should reset to initial value | COMMENT |
| LOW | …_backed_component_tests/test_state_backed_component.py | 488 | # Step 5: Load with DAGSTER_IS_DEV_CLI set - should force local refresh | COMMENT |
| LOW⚡ | …ons/declarative_automation/operators/since_operator.py | 139 | # Step 1: Add all newly-true trigger partitions | COMMENT |
| LOW⚡ | …ons/declarative_automation/operators/since_operator.py | 142 | # Step 2: Remove all newly-true reset partitions | COMMENT |
| LOW⚡ | …ons/declarative_automation/operators/since_operator.py | 145 | # Step 3: Use TimingMetadata to re-add partitions where trigger fired after reset | COMMENT |
| LOW | …ster/_core/definitions/partitions/utils/time_window.py | 212 | # (don't add it now, because we need to check if it overlaps with the next high pri) | COMMENT |
| LOW | …ster/_core/definitions/partitions/utils/time_window.py | 231 | # in the next iteration. (don't add it now, because we need to check if it overlaps with the next high p | COMMENT |
| LOW⚡ | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 781 | # Step 3: Agent is stuck - actual == desired but _grpc_servers has an error | COMMENT |
| LOW⚡ | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 786 | # Step 4: Next workspace query - server reports no error (hasLoadError=False). | COMMENT |
| LOW⚡ | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 799 | # Step 5: Location should be healthy again | COMMENT |
| LOW | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 735 | # Step 1: Deploy successfully | COMMENT |
| LOW | …r-cloud/dagster_cloud_tests/test_user_code_launcher.py | 749 | # Step 2: _refresh_actual_entries detects server moved to error state. | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 200 | # Step 0: Auto-prepare if requested | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 204 | # Step 1: Verify PR exists (skip if we have context) | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 212 | # Step 2: Update PR title | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 217 | # Step 3: Update PR body | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 222 | # Step 4: Update commit message | COMMENT |
| LOW⚡ | …on/automation/dagster_dev/commands/ai_review_update.py | 232 | # Step 5: Display success and Graphite URL | COMMENT |
| LOW | …er_basics_tutorial/src/dagster_tutorial/defs/assets.py | 1 | # Step 1: Define the assets | COMMENT |
| LOW | …er_basics_tutorial/src/dagster_tutorial/defs/assets.py | 23 | # Step 2: Define the assets with resources | COMMENT |
| LOW | …er_basics_tutorial/src/dagster_tutorial/defs/assets.py | 93 | # Step 3: Define assets with dependencies | STRING |
| LOW | …er_basics_tutorial/src/dagster_tutorial/defs/assets.py | 131 | # Step 4: Define asset_checks | STRING |
| LOW | …ry/use_case_repository/guides/snowflake_to_s3_sling.py | 7 | # Step 2: Define Sling Connections | COMMENT |
| LOW | …ry/use_case_repository/guides/snowflake_to_s3_sling.py | 28 | # Step 3: Define the Data Ingestion Asset | COMMENT |
| LOW⚡ | …src/project_mini/defs/dynamic_fanout/dynamic_fanout.py | 94 | # Step 1: Extract processing units from record (10-30 units) | COMMENT |
| LOW⚡ | …src/project_mini/defs/dynamic_fanout/dynamic_fanout.py | 98 | # Step 2: Process each unit (Second layer of parallelization) | COMMENT |
| LOW⚡ | …src/project_mini/defs/dynamic_fanout/dynamic_fanout.py | 108 | # Step 3: Aggregate results to create final record output | COMMENT |
| LOW⚡ | …src/project_mini/defs/dynamic_fanout/dynamic_fanout.py | 140 | # Step 1: Extract processing units from record (10-30 units) | COMMENT |
| LOW⚡ | …src/project_mini/defs/dynamic_fanout/dynamic_fanout.py | 144 | # Step 2: Process each unit (Second layer of parallelization) | COMMENT |
| LOW | …src/project_mini/defs/dynamic_fanout/dynamic_fanout.py | 159 | # Step 3: Aggregate results to create final record output | COMMENT |
| LOW | js_modules/ui-core/src/gantt/GanttChartLayout.ts | 38 | // Step 1: Place the nodes that have no dependencies into the layout. | COMMENT |
| LOW⚡ | js_modules/ui-core/src/gantt/GanttChartLayout.ts | 53 | // Step 2: Recursively iterate through the graph and insert child nodes | COMMENT |
| LOW⚡ | js_modules/ui-core/src/gantt/GanttChartLayout.ts | 60 | // Step 3: Assign X values (pixels) to each box by traversing the graph from the | COMMENT |
| LOW | js_modules/ui-core/src/gantt/GanttChartLayout.ts | 80 | // Step 4: Assign Y values (row numbers not pixel values) | COMMENT |
| LOW | js_modules/ui-core/src/gantt/toGraphQueryItems.tsx | 26 | // Step 1: Find unresolved steps in the initial plan and build a mapping | COMMENT |
| LOW | js_modules/ui-core/src/gantt/toGraphQueryItems.tsx | 53 | // Step 2: Create a graph node for each resolved step without any inputs or outputs. | COMMENT |
| LOW | js_modules/ui-core/src/gantt/toGraphQueryItems.tsx | 67 | // Step 3: For each step in the original plan, visit each input and create inputs/outputs | COMMENT |
| LOW⚡ | …les/ui-core/src/asset-data/AssetHealthDataProvider.tsx | 212 | // Step 1: Categorize keys based on whether they have definitions | COMMENT |
| LOW⚡ | …les/ui-core/src/asset-data/AssetHealthDataProvider.tsx | 218 | // Step 2: Fetch live data for keys with definitions | COMMENT |
| LOW⚡ | …les/ui-core/src/asset-data/AssetHealthDataProvider.tsx | 225 | // Step 3: Create empty fragments for keys without definitions | COMMENT |
| LOW⚡ | …les/ui-core/src/asset-data/AssetHealthDataProvider.tsx | 231 | // Step 4: Merge live data with empty fragments | COMMENT |
| LOW⚡ | …les/ui-core/src/asset-data/AssetHealthDataProvider.tsx | 237 | // Step 5: Block trace until data is ready | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …r_cloud_tests/workspace_tests/ecs_tests/test_client.py | 334 | # In this example, there is a service event that shows unavailable cluster resources. | COMMENT |
| HIGH | …cs/docs/integrations/libraries/motherduck/reference.md | 78 | {/* TODO fix link A partition must be selected when materializing the above assets, as described in the [Materializing p | CODE |
| HIGH | …cs/docs/integrations/libraries/motherduck/reference.md | 106 | {/* TODO fix link: A partition must be selected when materializing the above assets, as described in the [Materializing | CODE |
| HIGH | docs/docs/integrations/libraries/snowflake/reference.md | 104 | {/* TODO fix link: When materializing the above assets, a partition must be selected, as described in [Materializing par | CODE |
| HIGH | docs/docs/integrations/libraries/snowflake/reference.md | 132 | {/* TODO fix link: When materializing the above assets, a partition must be selected, as described in [Materializing par | CODE |
| HIGH | …/docs/integrations/libraries/gcp/bigquery/reference.md | 99 | When materializing the above assets, a partition must be selected, as described in the [Partitioning assets](/guides/bui | CODE |
| HIGH | docs/docs/integrations/libraries/iceberg/usage.md | 62 | A partition must be selected when materializing the above assets, as described in the [Materializing partitioned ass | CODE |
| HIGH | …ocs/deployment/dagster-plus/hybrid/kubernetes/setup.md | 294 | `envSecrets` will make the secret available in an environment variable, see the Kubernetes docs on [`envFrom` for detail | CODE |
| HIGH | …ocs/deployment/dagster-plus/hybrid/kubernetes/setup.md | 309 | `env_secrets` will make the secret available in an environment variable, see the Kubernetes docs on [`envFrom` for detai | CODE |
| HIGH | …cs/docs/examples/best-practices/dynamic-vs-parallel.md | 20 | [Dynamic outputs](/api/dagster/dynamic#dagster.DynamicOutput) allow you to create separate op executions for each item. | CODE |
| HIGH | …/project_dbt/src/project_dbt/analytics/dbt_project.yml | 30 | # In this example config, we tell dbt to build all models in the example/ | COMMENT |
| HIGH | …les/project_fully_featured/dbt_project/dbt_project.yml | 29 | # In this example config, we tell dbt to build all models in the example/ directory | COMMENT |
| HIGH | …ect_analytics/dagster_pypi/dbt_project/dbt_project.yml | 31 | # In this example config, we tell dbt to build all models in the example/ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …aries/dagster-snowflake/dagster_snowflake/resources.py | 613 | def process_data(snowflake: SnowflakeResource): | STRING |
| LOW | …ow_tests/test_dagster_job_factory/test_dag_run_conf.py | 20 | def test_function(**kwargs): | CODE |
| LOW | …sts/test_persistent_db/test_persistent_airflow_2_db.py | 36 | def test_function(**kwargs): | CODE |
| LOW | …sts/test_persistent_db/test_persistent_airflow_2_db.py | 109 | def test_function(**kwargs): | CODE |
| LOW | …sts/test_persistent_db/test_persistent_airflow_2_db.py | 163 | def test_function(**kwargs): | CODE |
| LOW | …sts/test_persistent_db/test_persistent_airflow_2_db.py | 276 | def test_function(**kwargs): | CODE |
| LOW | …libraries/dagster-databricks/dagster_databricks/ops.py | 85 | def do_stuff(): | STRING |
| LOW | …libraries/dagster-databricks/dagster_databricks/ops.py | 192 | def do_stuff(): | STRING |
| LOW | …dagster-aws/dagster_aws_tests/ecs_tests/stubbed_ecs.py | 364 | def run_task(self, **kwargs): | CODE |
| LOW | …er_aws_tests/ecs_tests/launcher_tests/test_failures.py | 7 | def run_task(self=ecs, **kwargs): | CODE |
| LOW | …er_aws_tests/ecs_tests/launcher_tests/test_failures.py | 53 | def run_task(*args, **kwargs): | CODE |
| LOW | …er_aws_tests/ecs_tests/launcher_tests/test_failures.py | 91 | def run_task(*args, **kwargs): | CODE |
| LOW | …er_aws_tests/ecs_tests/launcher_tests/test_failures.py | 120 | def run_task(*args, **kwargs): | CODE |
| LOW | …er_aws_tests/ecs_tests/launcher_tests/test_failures.py | 156 | def run_task(self, **_kwargs): | CODE |
| LOW | …/dagster-aws/dagster_aws_tests/pipes_tests/fake_ecs.py | 67 | def run_task(self, **kwargs): | CODE |
| LOW | …/dagster-aws/dagster_aws_tests/pipes_tests/test_ecs.py | 265 | def run_task(self, **kwargs): | CODE |
| LOW | …s/execution_tests/misc_execution_tests/test_retries.py | 725 | def do_something(my_resource: FailOnceResource): | CODE |
| LOW | …agster_tests/definitions_tests/test_reconstructable.py | 57 | def test_function(): | CODE |
| LOW | …/dagster_tests/definitions_tests/test_sensor_result.py | 8 | def do_something(): | CODE |
| LOW | …_tests/definitions_tests/test_repository_definition.py | 1562 | def do_something(): | CODE |
| LOW | …er/dagster_tests/general_tests/grpc_tests/grpc_repo.py | 8 | def do_something(): | CODE |
| LOW | …_tests/general_tests/utils_tests/test_cached_method.py | 23 | def my_method(self, arg1) -> tuple: | CODE |
| LOW | …_tests/general_tests/utils_tests/test_cached_method.py | 46 | def my_method(self, arg1, arg2) -> tuple: | CODE |
| LOW | …_tests/general_tests/utils_tests/test_cached_method.py | 65 | def my_method(self, _arg1: LeakTestKey) -> LeakTestValue: | CODE |
| LOW | …_tests/general_tests/utils_tests/test_cached_method.py | 149 | async def my_method(self, arg1) -> tuple: | CODE |
| LOW | …er/dagster_tests/cli_tests/command_tests/extra_repo.py | 5 | def do_something(): | CODE |
| LOW | …ter_tests/cli_tests/command_tests/test_cli_commands.py | 32 | def do_something(): | CODE |
| LOW | …ules/dagster/dagster_tests/api_tests/api_tests_repo.py | 11 | def do_something(): | CODE |
| LOW | …agster_tests/api_tests/test_api_snapshot_repository.py | 94 | def do_something(): | CODE |
| LOW | …/dagster/dagster_tests/asset_defs_tests/test_assets.py | 1701 | def my_function(): | CODE |
| LOW | …gster/dagster_tests/asset_defs_tests/test_asset_job.py | 1471 | def do_something(x): | CODE |
| LOW | …dagster_tests/core_tests/test_mask_user_code_errors.py | 235 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …/core_tests/resource_tests/test_resource_parameters.py | 198 | def do_something(self): | CODE |
| LOW | …s/resource_tests/pythonic_resources/test_configured.py | 18 | def do_something(my_resource: MyResource) -> str: | CODE |
| LOW⚡ | …s/resource_tests/pythonic_resources/test_configured.py | 43 | def do_something(my_resource: MyResource) -> str: | CODE |
| LOW | …s/resource_tests/pythonic_resources/test_configured.py | 78 | def do_something(my_resource: MyResource) -> str: | CODE |
| LOW | …s/resource_tests/pythonic_resources/test_configured.py | 144 | def do_something(my_resource: MyResource) -> str: | CODE |
| LOW | …s/resource_tests/pythonic_resources/test_configured.py | 167 | def do_something(my_resource: MyResource) -> str: | CODE |
| LOW⚡ | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 14 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 31 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 65 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 92 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 121 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 146 | def do_something(config: DoSomethingConfig) -> MyEnum: | CODE |
| LOW⚡ | …_tests/core_tests/pythonic_config_tests/test_graphs.py | 174 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …ts/core_tests/pythonic_config_tests/test_configured.py | 13 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …ts/core_tests/pythonic_config_tests/test_configured.py | 42 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …ts/core_tests/pythonic_config_tests/test_configured.py | 71 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …ts/core_tests/pythonic_config_tests/test_configured.py | 93 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …s/core_tests/pythonic_config_tests/test_jobs_graphs.py | 14 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …s/core_tests/pythonic_config_tests/test_jobs_graphs.py | 31 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …s/core_tests/pythonic_config_tests/test_jobs_graphs.py | 58 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW⚡ | …s/core_tests/pythonic_config_tests/test_jobs_graphs.py | 87 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …s/core_tests/pythonic_config_tests/test_jobs_graphs.py | 112 | def do_something(config: DoSomethingConfig) -> MyEnum: | CODE |
| LOW⚡ | …s/core_tests/pythonic_config_tests/test_jobs_graphs.py | 140 | def do_something(config: DoSomethingConfig) -> str: | CODE |
| LOW | …ter/dagster_tests/core_tests/graph_tests/test_graph.py | 145 | def do_stuff(context): | CODE |
| LOW | …ter/dagster_tests/core_tests/graph_tests/test_graph.py | 180 | def do_stuff(context): | CODE |
| LOW | …_core/definitions/decorators/source_asset_decorator.py | 254 | def my_function(): | STRING |
| LOW | …agster/_core/definitions/decorators/asset_decorator.py | 690 | def my_function(): | STRING |
| LOW | …agster/_core/definitions/decorators/asset_decorator.py | 703 | def my_function(asset0): | STRING |
| 8 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …es/dagster-airbyte/dagster_airbyte/legacy_resources.py | 246 | # if Airbyte sync has not completed, make sure to cancel it so that it doesn't outlive | COMMENT |
| LOW | …es/dagster-airbyte/dagster_airbyte/legacy_resources.py | 629 | # if Airbyte sync has not completed, make sure to cancel it so that it doesn't outlive | COMMENT |
| LOW | …libraries/dagster-airbyte/dagster_airbyte/resources.py | 453 | # if Airbyte sync has not completed, make sure to cancel it so that it doesn't outlive | COMMENT |
| LOW | …libraries/dagster-tableau/dagster_tableau/resources.py | 344 | # if any Tableau syncs have not completed, make sure to cancel them so they don't outlive | COMMENT |
| LOW | …es/dagster-shared/dagster_shared/telemetry/__init__.py | 115 | # last action, we need to make sure to re-create the directory | COMMENT |
| MEDIUM | …_defs/pythonic_components/relative_import/component.py | 9 | """A simple component class for demonstration purposes.""" | STRING |
| MEDIUM | …finitions/both_python_defs_and_components/top_level.py | 9 | """A simple component class for demonstration purposes.""" | STRING |
| MEDIUM | …_names_at_levels/folder_with_component_py/component.py | 6 | """A simple component class for demonstration purposes.""" | STRING |
| LOW | …ative_automation_tests/scenario_utils/base_scenario.py | 236 | # make sure to log the planned events | COMMENT |
| LOW | python_modules/dagster/dagster/_core/execution/api.py | 687 | # If you have repository_load_data, make sure to use it when building plan | COMMENT |
| LOW | …hon_modules/dagster/dagster/_core/definitions/input.py | 103 | # when adding new params, make sure to update combine_with_inferred and with_dagster_type below | COMMENT |
| LOW | …ore/definitions/assets/definition/assets_definition.py | 155 | # if adding new fields, make sure to handle them in the with_attributes, from_graph, | COMMENT |
| LOW | python_modules/dagster/dagster/_daemon/asset_daemon.py | 1037 | # make sure to override the evaluation id to stay on the previous value | COMMENT |
| MEDIUM | …egrations/powerbi-component/6-populated-component.yaml | 11 | # Alternatively, you can use an API access token | COMMENT |
| MEDIUM | …ides/components/integrations/test_powerbi_component.py | 129 | # Alternatively, you can use an API access token | STRING |
| MEDIUM | helm/dagster/values.yaml | 927 | # If your Redis connection needs configuration options, you can use this field to specific the | COMMENT |
| LOW | helm/dagster/values.yaml | 56 | # Defines the port where the webserver will serve requests; if changed, don't forget to update the | COMMENT |
| LOW | helm/dagster/values.yaml | 56 | # Defines the port where the webserver will serve requests; if changed, don't forget to update the | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py | 847 | CODE | |
| MEDIUM | …dagster_tests/storage_tests/test_instigation_logger.py | 26 | CODE | |
| MEDIUM | …dagster/dagster_tests/storage_tests/test_io_manager.py | 488 | CODE | |
| MEDIUM | …tion_tests/execution_plan_tests/test_execution_plan.py | 505 | CODE | |
| MEDIUM | …dagster/dagster_tests/core_tests/test_job_execution.py | 969 | CODE | |
| MEDIUM | …r/dagster_tests/core_tests/hook_tests/test_hook_run.py | 299 | CODE | |
| MEDIUM | python_modules/dagster/dagster/_generate/generate.py | 48 | CODE | |
| MEDIUM | …suites/daemon-test-suite/test_dagster_daemon_health.py | 114 | CODE | |
| MEDIUM | …project_snowflake_dynamic_tables/tests/test_sensors.py | 60 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …-dg-cli/dagster_dg_cli/cli/scaffold/branch/planning.py | 29 | markdown_content: The complete plan as markdown text generated by Claude | STRING |
| HIGH | …ples/docs_projects/project_dspy/dspy_modules/puzzle.py | 291 | test_set = shuffled # Test on all puzzles as requested | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …les/docs_snippets/docs_snippets/integrations/qdrant.py | 29 | api_key="<your-api-key>", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ibraries/dagster-gcp/dagster_gcp/dataproc/resources.py | 72 | # TODO: Add logging | COMMENT |
| LOW | …ibraries/dagster-gcp/dagster_gcp/dataproc/resources.py | 107 | # TODO: Add logging here print('Waiting for job ID {} to finish...'.format(job_id)) | COMMENT |
| LOW | …dagster-cloud/dagster_cloud/execution/utils/process.py | 18 | # TODO: implement cross platform process check | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/components_tests/scaffoldable_tests/test_decorator.py | 7 | # Example usage: | COMMENT |
| LOW | …_modules/dagster-cloud/dagster_cloud_tests/conftest.py | 54 | # Usage: | COMMENT |