faucet-cli 1.16.0
high severity exfiltration_endpoint in test code: https://hooks.slack.com/services/T0/B0/x
19
low
Automated verdict. Nobody reviewed it. A score is a reason to look closer, not a finding.
Evidence
| Points | Signal | Where | What |
|---|---|---|---|
| 10 | static:exfiltration_endpoint static · faucet-cli | tests/cli_end_to_end.rs:858 | high severity exfiltration_endpoint in test code: https://hooks.slack.com/services/T0/B0/x |
| 2 | static:credential_access static · faucet-cli | src/executor.rs:4218 | medium severity credential_access in library code: /home/svc/.ssh/authorized_keys |
| 2 | static:environment_enumeration static · faucet-cli | src/env_config.rs:407 | medium severity environment_enumeration in library code (2 places): std::env::vars_os |
| 2 | static:secret_environment_variable static · faucet-cli | src/hub/remote.rs:167 | medium severity secret_environment_variable in library code (6 places): GITHUB_TOKEN |
| 2 | static:yara:persistence_locations static · faucet-cli | README.md:587 | medium severity yara:persistence_locations in library code (2 places): Paths and keys used to persist on a developer machine |
| 1 | static:build_script static · faucet-cli | build.rs | low severity build_script in build_script code: build.rs |
Behavior
New since the previous version
static:credential_access
Profile
static:credential_access static:environment_enumeration static:exfiltration_endpoint static:secret_environment_variable static:yara:persistence_locations
Static findings
16 groups
high exfiltration_endpoint test 1
https://hooks.slack.com/services/T0/B0/xtests/cli_end_to_end.rs:858
medium secret_environment_variable library 3
GITHUB_TOKENsrc/hub/remote.rs:167 src/hub/remote.rs:1075AZURE_CLIENT_SECRETsrc/secrets/azure_kv.rs:79
medium secret_environment_variable test 3
GITHUB_TOKENtests/cli_end_to_end.rs:824 tests/hub_cli.rs:709GOOGLE_APPLICATION_CREDENTIALStests/cli_end_to_end.rs:852
medium yara_match persistence_locations library 2
Paths and keys used to persist on a developer machineREADME.md:587 src/executor.rs:4206
medium credential_access library 1
/home/svc/.ssh/authorized_keyssrc/executor.rs:4218
medium environment_enumeration library 1
std::env::vars_ossrc/env_config.rs:407
low network_access test 189
std::net::TcpListener::bindtests/rest_fanout_path_encode.rs:94 tests/serve_backfill.rs:73 tests/serve_history_sqlite.rs:397 tests/serve_http_hardening.rs:65 tests/serve_log_shipping.rs:635 tests/serve_skeleton.rs:70 tests/support/ports.rs:17reqwest::Client::newtests/rest_fanout_path_encode.rs:120 tests/serve_backfill.rs:82 tests/serve_callback.rs:79 tests/serve_callback.rs:146 tests/serve_callback.rs:190 tests/serve_callback.rs:228 tests/serve_callback.rs:275 tests/serve_callback.rs:321 tests/serve_callback.rs:358 tests/serve_callback.rs:413 tests/serve_callback.rs:460 tests/serve_catalog.rs:87 tests/serve_catalog.rs:158 tests/serve_catalog.rs:332 tests/serve_changes.rs:112 tests/serve_changes.rs:208 tests/serve_changes.rs:718 tests/serve_changes.rs:904 tests/serve_changes.rs:944 tests/serve_cluster.rs:201 tests/serve_cluster.rs:480 tests/serve_cluster_secret_params.rs:97 tests/serve_dlq.rs:86 tests/serve_dlq.rs:132 tests/serve_error_redaction.rs:49 tests/serve_error_redaction.rs:89 tests/serve_history_degraded.rs:254 tests/serve_history_sqlite.rs:457 tests/serve_http_hardening.rs:83 tests/serve_lifecycle.rs:78 tests/serve_lifecycle.rs:127 tests/serve_lifecycle.rs:170 tests/serve_lifecycle.rs:233 tests/serve_lifecycle.rs:282 tests/serve_lifecycle.rs:368 tests/serve_lifecycle.rs:423 tests/serve_lifecycle.rs:539 tests/serve_local_outputs.rs:115 tests/serve_local_outputs.rs:202 tests/serve_local_outputs.rs:342 tests/serve_local_outputs.rs:399 tests/serve_local_outputs.rs:528 tests/serve_local_outputs.rs:598 tests/serve_local_outputs.rs:645 tests/serve_local_outputs.rs:706 tests/serve_local_outputs.rs:776 tests/serve_local_outputs.rs:846 tests/serve_log_shipping.rs:650 tests/serve_logs.rs:78 tests/serve_logs.rs:111 and 69 morereqwest::Clienttests/serve_backfill.rs:65 tests/serve_backfill.rs:72 tests/serve_backfill.rs:225 tests/serve_catalog.rs:107 tests/serve_catalog.rs:115 tests/serve_changes.rs:130 tests/serve_cluster_secret_params.rs:91 tests/serve_error_redaction.rs:64 tests/serve_local_outputs.rs:135 tests/serve_local_outputs.rs:174 tests/serve_policy_plan.rs:133 tests/serve_policy_plan.rs:167 tests/serve_preview.rs:152 tests/serve_preview.rs:195 tests/serve_preview.rs:222 tests/serve_run_depends_on.rs:74 tests/serve_sql_sandbox.rs:74 tests/serve_sql_sandbox.rs:104 tests/serve_sql_sandbox.rs:120 tests/serve_state_status.rs:127 tests/serve_state_status.rs:146 tests/serve_template_version_deprecation.rs:71 tests/serve_templates_owner_ids.rs:71 tests/serve_templates_sync.rs:77 tests/serve_tenants.rs:94 tests/serve_trust_boundaries.rs:73 tests/serve_ui.rs:66 tests/serve_usage.rs:102 tests/serve_verify_rollback.rs:155 tests/support/template_server.rs:69 tests/template_selection.rs:75 tests/topology_runtimes.rs:561tokio::net::TcpListener::bindtests/serve_history_degraded.rs:245 tests/serve_history_degraded.rs:343 tests/serve_otel.rs:38 tests/support/otlp_mock.rs:173 tests/support/otlp_mock.rs:397reqwest::gettests/serve_history_degraded.rs:355 tests/serve_http_hardening.rs:72 tests/serve_pools.rs:263reqwest::Method::OPTIONStests/serve_http_hardening.rs:88reqwest::Methodtests/serve_openapi.rs:219 tests/serve_tenants.rs:100 tests/serve_trust_boundaries.rs:79reqwest::Method::POSTtests/serve_tenants.rs:121 tests/serve_trust_boundaries.rs:100reqwest::Method::GETtests/serve_tenants.rs:124 tests/serve_trust_boundaries.rs:103reqwest::Client::buildertests/serve_tenants.rs:187reqwest::redirect::Policy::nonetests/serve_tenants.rs:188reqwest::Method::DELETEtests/serve_tenants.rs:562 tests/serve_tenants.rs:890 tests/serve_tenants.rs:907 tests/serve_tenants.rs:1018reqwest::Url::parsetests/serve_tenants.rs:668 tests/serve_tenants.rs:720 tests/serve_tenants.rs:928reqwest::Method::PUTtests/serve_tenants.rs:781reqwest::Method::PATCHtests/serve_tenants.rs:803 tests/serve_tenants.rs:840 tests/serve_tenants.rs:864 tests/serve_tenants.rs:875 tests/serve_tenants.rs:1353
low network_access library 64
reqwest::Clientsrc/hub/remote.rs:66 src/logship/otlp.rs:154 src/secrets/gcp_sm.rs:17 src/secrets/mod.rs:43 src/secrets/vault.rs:15 src/templates/sync/fetch.rs:304reqwest::Responsesrc/hub/remote.rs:99 src/hub/remote.rs:119 src/hub/remote.rs:217 src/hub/remote.rs:224 src/hub/remote.rs:226 src/notify/channels.rs:107 src/templates/sync/fetch.rs:440 src/templates/sync/fetch.rs:448 src/templates/sync/fetch.rs:448reqwest::RequestBuildersrc/hub/remote.rs:205 src/hub/remote.rs:217 src/templates/sync/fetch.rs:428 src/templates/sync/fetch.rs:440reqwest::Client::newsrc/hub/remote.rs:931reqwest::Errorsrc/logship/otlp.rs:414tokio::net::TcpListener::bindsrc/logship/otlp.rs:597 src/serve/server.rs:1036reqwest::Method::from_bytessrc/notify/channels.rs:63 src/serve/callback.rs:122 src/serve/callback.rs:425reqwest::header::CONTENT_TYPEsrc/notify/channels.rs:67 src/serve/callback.rs:432reqwest::header::HeaderName::from_bytessrc/notify/spec.rs:297reqwest::header::HeaderValue::from_strsrc/notify/spec.rs:308reqwest::StatusCode::NOT_FOUNDsrc/secrets/gcp_sm.rs:84 src/secrets/vault.rs:59 src/templates/sync/fetch.rs:592reqwest::StatusCode::FORBIDDENsrc/secrets/vault.rs:65reqwest::StatusCode::UNAUTHORIZEDsrc/secrets/vault.rs:66reqwest::Url::parsesrc/serve/callback.rs:144 src/serve/callback.rs:410 src/serve/callback.rs:491 src/serve/callback.rs:496 src/serve/callback.rs:501 src/serve/callback.rs:508 src/serve/callback.rs:564 src/serve/callback.rs:567 src/serve/callback.rs:569 src/serve/tenants/connect.rs:88 src/serve/tenants/connect.rs:133 src/serve/tenants/connect.rs:323 src/serve/tenants/connect.rs:552 src/serve/tenants/connect.rs:569reqwest::Urlsrc/serve/callback.rs:368 src/serve/tenants/connect.rs:87tokio::net::lookup_hostsrc/serve/callback.rs:388reqwest::StatusCode::REQUEST_TIMEOUTsrc/serve/callback.rs:444reqwest::StatusCode::TOO_MANY_REQUESTSsrc/serve/callback.rs:445reqwest::Url::parse_with_paramssrc/serve/tenants/connect.rs:159reqwest::header::ACCEPTsrc/serve/tenants/connect.rs:488reqwest::Method::GETsrc/templates/sync/fetch.rs:383 src/templates/sync/fetch.rs:472 src/templates/sync/fetch.rs:505 src/templates/sync/fetch.rs:551 src/templates/sync/fetch.rs:585 src/templates/sync/fetch.rs:689reqwest::Methodsrc/templates/sync/fetch.rs:428reqwest::Method::PUTsrc/templates/sync/fetch.rs:725
low process_spawn test 10
low build_script build_script 1
build.rsbuild.rs
low process_spawn library 1
std::process::Command::newsrc/pipeline_state/lease.rs:1002
info url_literal library 679
https://idp/token\u{0}appsrc/auth_catalog.rs:146\u{a}version: 1\u{a}name: orders\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config: { url: "https://api.example.com/orders?since=${backfill.start}&until=${backfill.end}" }\u{a} sink:\u{a}…src/backfill/orchestrator.rs:887\u{a}version: 1\u{a}name: orders\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://api.example.com/orders" } }\u{a} sink: { type: jsonl, config: { path: ./out.jsonl, append: true } …src/backfill/orchestrator.rs:950s3://b/exports/orders.jsonlsrc/backfill/orchestrator.rs:1006\u{a}version: 1\u{a}name: orders\u{a}pipeline:\u{a} sources:\u{a} default:\u{a} type: rest\u{a} config: { url: "https://api.example.com/x?s=${backfill.start}" }\u{a} sinks:\u{a} defa…src/backfill/orchestrator.rs:1083\u{a}version: 1\u{a}name: orders\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config: { url: "https://api.example.com/x?s=${backfill.start}" }\u{a} sink: { type: jsonl, config: { path: ./ou…src/backfill/orchestrator.rs:1106postgres://src/catalog/mod.rs:102 src/pipeline_state/ops.rs:1080 src/serve/config.rs:330 src/templates/store.rs:1801postgresql://src/catalog/mod.rs:102 src/pipeline_state/ops.rs:1080 src/serve/config.rs:330 src/templates/store.rs:1801catalog.url '{other}' is not recognised — expected 'memory', 'sqlite:<path>', or a 'postgres://…' URLsrc/catalog/mod.rs:107mysql://nopesrc/catalog/mod.rs:234 src/templates/store.rs:3292postgres://h/dbsrc/catalog/mod.rs:250 src/replication/tables.rs:717 src/serve/history/catalog.rs:1002postgresql://h/dbsrc/catalog/mod.rs:254csv://insrc/catalog/mod.rs:306csv://outsrc/catalog/mod.rs:307 src/catalog/mod.rs:318 src/catalog/mod.rs:332file://./out/dt=20260706/x.jsonlsrc/catalog/model.rs:143file://./out/dt=${now.year}${now.month}${now.day}/x.jsonlsrc/catalog/model.rs:146file://./out/202607src/catalog/model.rs:150file://./out/${now.year}${now.month}src/catalog/model.rs:151file://./out/dt=2026-07-06/part.jsonlsrc/catalog/model.rs:158file://./out/dt=${now.date}/part.jsonlsrc/catalog/model.rs:159file://./out/2026/07/x.jsonlsrc/catalog/model.rs:165file://./out/${now.strftime.%Y/%m}/x.jsonlsrc/catalog/model.rs:166postgres://u:pw@h:5432/db/public.userssrc/catalog/model.rs:172s3://bucket-07/data/07/part.jsonlsrc/catalog/model.rs:209s3://bucket-07/data/${now.month}/part.jsonlsrc/catalog/model.rs:210postgres://db:5432/prod <secret:hmac:src/catalog/snapshot.rs:666\u{a}version: 1\u{a}name: mypipe\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} url: https://api.example.com/v1\u{a} auth: { type: bearer, config: { token: topsecretvalu…src/catalog/snapshot.rs:699version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { url: https://x/y } }\u{a} sink: { type: jsonl, config: { path: o.jsonl } }\u{a}src/catalog/snapshot.rs:744file:///in{i}src/commands/catalog.rs:479file:///out{i}src/commands/catalog.rs:480csv://./in.csvsrc/commands/catalog.rs:564 src/serve/history/catalog.rs:812 src/serve/history/catalog.rs:814 src/serve/history/catalog.rs:846 src/serve/history/catalog.rs:852 src/serve/history/catalog.rs:867 src/serve/history/catalog.rs:875 src/serve/history/catalog.rs:894 src/serve/history/catalog.rs:902 src/serve/history/memory.rs:2467 src/serve/history/memory.rs:2475 src/serve/history/memory.rs:2483 src/serve/history/memory.rs:2499 src/serve/history/sqlite.rs:459 src/serve/history/sqlite.rs:501 src/serve/history/sqlite.rs:504jsonl://./out.jsonlsrc/commands/catalog.rs:571 src/serve/history/memory.rs:2468 src/serve/history/memory.rs:2476 src/serve/history/memory.rs:2484 src/serve/history/sqlite.rs:466csv://./in.csv → jsonl://./out.jsonlsrc/commands/catalog.rs:582file:///tmp/asrc/commands/cleanup.rs:385 src/local_outputs/ledger.rs:769 src/local_outputs/metrics.rs:90\u{a}version: 1\u{a}name: demo\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://example.com" } }\u{a} sink: { type: jsonl, config: { path: out.jsonl, append: true } }\u{a}matrix:…src/commands/completions.rs:190https://github.com/faucet-hq/faucet-stream/tree/vsrc/commands/contract.rs:13\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: postgres\u{a} config: { connection_url: "postgres://x", query: "SELECT 1" }\u{a} sinks:\u{a} lake:\u{a} type: s3\u{a} config:…src/commands/discover.rs:972\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} default:\u{a} type: rest\u{a} config: { base_url: "https://api.example.com" }\u{a} sinks:\u{a} bigquery:\u{a} type: jsonl\u{a} …src/commands/discover.rs:1025\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} warehouse:\u{a} type: postgres\u{a} config: { connection_url: "postgres://x", query: "SELECT 1" }\u{a} sinks:\u{a} default:\u{a} …src/commands/discover.rs:1052version: 1\u{a}name: conn\u{a}pipeline:\u{a} source:\u{a} type: sqlite\u{a} config:\u{a} database_url: 'sqlite://{db}'\u{a} query: SELECT 1\u{a} sink:\u{a} type: jsonl\u{a} con…src/commands/discover.rs:1113sqlite://{db}?mode=rwcsrc/commands/discover.rs:1122\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x", auth: { ref: idp } } }\u{a} sink: { type: jsonl, config: { path: out.jsonl } }\u{a}auth:\u{a} idp: { type: …src/commands/doctor.rs:1396\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x", auth: { ref: missing } } }\u{a} sink: { type: jsonl, config: { path: out.jsonl } }\u{a}src/commands/doctor.rs:1409\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x" } }\u{a} sink: { type: jsonl, config: { path: out.jsonl } }\u{a}auth:\u{a} unused_idp: { type: static, confi…src/commands/doctor.rs:1425\u{a}version: 1\u{a}vars:\u{a} used: "https://x"\u{a} never: 5\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "${vars.used}" } }\u{a} sink: { type: jsonl, config: { path: out.jsonl }…src/commands/doctor.rs:1441\u{a}version: 1\u{a}vars:\u{a} base: "https://x"\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "${vars.base}" } }\u{a} sink: { type: jsonl, config: { path: out.jsonl } }\u{a}replicat…src/commands/doctor.rs:1467extends: base.yaml\u{a}version: 1\u{a}vars:\u{a} host: https://x\u{a}src/commands/doctor.rs:1497\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x" } }\u{a} sink: { type: jsonl, config: { path: out.jsonl, batch_size: 0 } }\u{a}src/commands/doctor.rs:1509base=https://apisrc/commands/doctor.rs:1566version: 1\u{a}name: inc\u{a}pipeline:\u{a} sources:\u{a} full_sql: { type: postgres, config: { connection_url: "postgres://h/db", query: "SELECT 1", replication: { type: full } } }\u{a} inc_sq…src/commands/explain.rs:320version: 1\u{a}name: d\u{a}pipeline:\u{a} sources:\u{a} api: { type: rest, config: { base_url: "https://x", path: "/" } }\u{a} sink: { type: jsonl, config: { path: "./${subs.id}.jsonl" } }\u{a}ma…src/commands/explain.rs:350\u{a}version: 1\u{a}name: fan\u{a}pipeline:\u{a} source: { type: rest, config: {} }\u{a} sink:\u{a} type: postgres\u{a} config:\u{a} connection_url: "postgres://localhost/db"\u{a} ta…src/commands/explain.rs:408kind: deployment\u{a}name: leaky\u{a}state: { type: postgres, config: { url: "postgres://u:pw@h/db" } }\u{a}src/commands/hub.rs:864# api_base: https://api.example.com\u{a}\u{a}src/commands/init.rs:451http://c:4318src/commands/logs.rs:171 src/commands/logs.rs:176 src/logship/otlp.rs:532http://c:4317src/commands/logs.rs:182version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "http://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}observability:\u{a} otel: { endpoint: "http://col:4317", export: […src/commands/logs.rs:185http://col:4317src/commands/logs.rs:188version: 1\u{a}source:\u{a} type: rest\u{a} config:\u{a} base_url: https://x\u{a} auth: { type: bearer, token: t }\u{a}sink:\u{a} type: jsonl\u{a} config: { path: out.jsonl }\u{a}src/commands/migrate.rs:645version: 1\u{a}name: n\u{a}notifications:\u{a} - name: s\u{a} channel:\u{a} type: slack\u{a} config:\u{a} webhook_url: http://127.0.0.1:1/hook\u{a}pipeline:\u{a} source:\u{a} …src/commands/notify.rs:260version: 1\u{a}name: q\u{a}pipeline:\u{a} source:\u{a} type: sqs\u{a} config:\u{a} queue_url: "http://127.0.0.1:1/000000000000/orders"\u{a} region: us-east-1\u{a} endpoint_url: "…src/commands/plan.rs:1009\u{a}version: 1\u{a}name: plain\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://example.com/api" } }\u{a} sink: { type: jsonl, config: { path: ./out.jsonl } }\u{a}src/commands/replicate.rs:188\u{a}version: 1\u{a}name: mirror\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: { connection_url: "postgres://x", slot_name: s, publication_name: p } }\u{a} sink: { type: postgres, confi…src/commands/replicate.rs:217 src/replication/compiled.rs:264version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://a } }\u{a} sink: { type: stdout, config: {} }\u{a}src/commands/replicate.rs:240\u{a}version: 1\u{a}name: mirror\u{a}pipeline:\u{a} source: {{ type: postgres-cdc, config: {{ connection_url: "postgres://u@127.0.0.1:1/db", slot_name: s, publication_name: p }} }}\u{a} sink: {{ t…src/commands/replicate.rs:262version: 1\u{a}name: m\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: https://a }} }}\u{a} sink: {{ type: stdout, config: {{}} }}\u{a} state: {{ type: file, config: {{ path: {} }} }…src/commands/replicate.rs:287version: 1\u{a}name: m\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: https://a }} }}\u{a} sink: {{ type: stdout, config: {{}} }}\u{a}{key}:\u{a} mode: snapshot_then_cdc\u{a} snaps…src/commands/replicate.rs:354sqlite:///x#tsrc/commands/rollback.rs:199 src/commands/rollback.rs:281 src/commands/rollback.rs:290 src/rollback/state.rs:188postgres://faucet:hunter2pw@db/templatessrc/commands/template.rs:1352postgres://db/templatessrc/commands/template.rs:1356version: 1\u{a}name: adapter-fixture\u{a}params:\u{a} tenant: { type: string, required: true }\u{a} region: { type: string, default: us, values: [us, eu] }\u{a}pipeline:\u{a} source:\u{a} type: …src/commands/template.rs:1896version: 1\u{a}name: adapter-registered\u{a}params:\u{a} tenant: { type: string, required: true }\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config: { base_url: "https://example.com", pat…src/commands/template.rs:2053\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: {} }\u{a} sink:\u{a} type: postgres\u{a} config:\u{a} connection_url: "postgres://localhost/db"\u{a} table_name: t…src/commands/validate.rs:869\u{a}version: 1\u{a}delivery: exactly_once\u{a}pipeline:\u{a} source:\u{a} type: postgres-cdc\u{a} config: { connection_url: "postgres://localhost/db", slot: s, publication: p }\u{a} sink:…src/commands/validate.rs:895sqlite:///a#tsrc/commands/verify.rs:162sqlite:///b#tsrc/commands/verify.rs:163version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config: { base_url: https://x }\u{a} auth: !include ./auth.yaml\u{a}src/compose.rs:558\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: https://api.example.com\u{a} sink:\u{a} type: jsonl\u{a} config:\u{a} path: ./out.jsonl…src/config.rs:1695 src/config.rs:1736\u{a}version: 1\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: { connection_url: "postgres://x", slot_name: s, publication_name: p } }\u{a} sink: { type: postgres, config: { connection_u…src/config.rs:1718 src/replication/orchestrator.rs:491\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://api.example.com } }\u{a} sink: { type: jsonl, config: { path: ./out.jsonl } }\u{a}matrix:\u{a} - id: users…src/config.rs:1772https://x.examplesrc/config.rs:1914 src/config.rs:1936 src/env_config.rs:820 src/env_config.rs:828 src/env_config.rs:879 src/env_config.rs:884 src/env_config.rs:977 src/env_config.rs:982 src/env_config.rs:1000 src/env_config.rs:1227 src/env_config.rs:1246\u{a}version: 1\u{a}name: x\u{a}observability:\u{a} prometheus:\u{a} listen: "127.0.0.1:9464"\u{a} buckets: [0.01, 0.1, 1.0]\u{a} tracing:\u{a} level: "info"\u{a}pipeline:\u{a} source:…src/config.rs:1943\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://api.example.com } }\u{a} sink: { type: jsonl, config: { path: ./out.jsonl } }\u{a}execution:\u{a} adaptive_bat…src/config.rs:2017\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://x" } }\u{a} quality:\u{a} record:\u{a} - { type: not_null, field: id, on_failure: abort }\u{a} sink: { type:…src/config.rs:2040\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://x" } }\u{a} contract:\u{a} version: "1.0.0"\u{a} on_breach: warn\u{a} fields:\u{a} - { name: id, type: …src/config.rs:2057\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} users_api:\u{a} type: rest\u{a} config: { base_url: https://api.example.com }\u{a} posts_api:\u{a} type: rest\u{a} config: {…src/config.rs:2159\u{a}version: 1\u{a}vars:\u{a} api_base: https://api.example.com\u{a} api_token_env: API_TOKEN\u{a}pipeline:\u{a} source: { type: rest, config: {} }\u{a} sink: { type: jsonl, config: { path: ./o…src/config.rs:2219https://api.example.comsrc/config.rs:2230 src/dynamic_fanout.rs:292 src/env_config.rs:1194 src/env_config.rs:1202 src/env_config.rs:1230 src/env_config.rs:1235 src/interpolate.rs:1554 src/serve/load.rs:3858 src/serve/references.rs:245 src/templates/store.rs:2312\u{a}version: 1\u{a}vars:\u{a} base: https://api.example.com\u{a}pipeline:\u{a} source: { type: rest, config: { url: "${vars.base}/v1" } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }…src/config.rs:2252https://api.example.com/v1src/config.rs:2265 src/serve/load.rs:3856\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }\u{a}src/config.rs:2322\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}resilience:\u{a} retry: { max_attempts: 4, backoff: exponent…src/config.rs:2438\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}resilience: { retry: { max_attempts: 0 } }\u{a}src/config.rs:2459\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "http://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}observability:\u{a} otel:\u{a} endpoint: http://collector:…src/config.rs:2473http://collector:4317src/config.rs:2486\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "http://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}observability:\u{a} otel:\u{a} sample_ratio: 9.0\u{a}src/config.rs:2491https://img.shields.io/badge/faucet-{}-{}src/conformance.rs:98https://docs.rs/{krate}src/connector_export.rs:306https://crates.io/crates/{krate}src/connector_export.rs:307://unknownsrc/destination.rs:189 src/topology.rs:795x://unknownsrc/destination.rs:597postgres://u:p@h/db?table=t/src/destination.rs:600postgres://u:q@h/db?table=tsrc/destination.rs:601://src/env_config.rs:453 src/hub/catalog.rs:558 src/replication/tables.rs:341 src/secrets/registry.rs:215 src/secrets/registry.rs:220 src/serve/load.rs:623 src/serve/load.rs:1521 src/serve/triggers/context.rs:630 src/serve/triggers/enqueue.rs:115postgres://app:p%40ss%2Fword@db.example:5432/appsrc/env_config.rs:706postgres://u:p@db-4417/xsrc/env_config.rs:757https://api-4417.example.comsrc/env_config.rs:760pg-pass-4417 orders-table-4417 postgres://u:p@db-4417/x https://api-4417.example.comsrc/env_config.rs:768*** orders-table-4417 *** https://api-4417.example.comsrc/env_config.rs:772postgres://h-5521/db?user=u&password=q%2Fpw-5521src/env_config.rs:789postgres://u:url-pw-5521@db/xsrc/env_config.rs:793https://usrc/env_config.rs:842 src/env_config.rs:853https://apisrc/env_config.rs:844 src/env_config.rs:869https://other.examplesrc/env_config.rs:991https://default.examplesrc/env_config.rs:1162https://users.examplesrc/env_config.rs:1167 src/env_config.rs:1179 src/expand.rs:4431https://posts.examplesrc/env_config.rs:1169https://xsrc/env_config.rs:1206 src/expand.rs:3314 src/expand.rs:3777 src/expand.rs:4214 src/expand.rs:4237 src/expand.rs:4351 src/serve/history/mod.rs:2568 src/serve/tenants/mod.rs:2174 src/serve/tenants/mod.rs:2180 src/serve/tenants/mod.rs:2325 src/serve/tenants/mod.rs:2326https://x/${customers.company}src/executor.rs:4145https://h/a%2Fb?q=1src/executor.rs:4184https://hook/a%2Fb/eventssrc/executor.rs:4194sqlite://{}?mode=rwcsrc/executor.rs:8598 src/status/tests.rs:373\u{a}version: 1\u{a}name: s\u{a}delivery: exactly_once\u{a}shard: {{ count: 2 }}\u{a}pipeline:\u{a} source: {{ type: kafka, config: {{ brokers: "localhost:9092", topics: [t], group_id: g, idle_timeou…src/expand.rs:2822\u{a}version: 1\u{a}name: s\u{a}{shard}\u{a}pipeline:\u{a} source: {{ type: {source}, config: {{ connection_url: "postgres://u@h/db", query: "SELECT * FROM t WHERE ts >= ${{bookmark}} ORDER BY ts", s…src/expand.rs:2853\u{a}version: 1\u{a}name: m\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: { connection_url: "postgres://u@h/db", slot_name: s, publication_name: p } }\u{a} transforms: [ { type: cdc_unwra…src/expand.rs:2930\u{a}version: 1\u{a}name: m\u{a}pipeline:\u{a} source:\u{a} type: mongodb-cdc\u{a} config: {{ connection_uri: "mongodb://h/?replicaSet=rs0", database: d, full_document: {full_document} }}\u{a} …src/expand.rs:3023\u{a}version: 1\u{a}auth:\u{a} login:\u{a} type: flow\u{a} config:\u{a} steps:\u{a} - request: {{ method: POST, url: "https://x/login" }}\u{a} capture: {{ session: "$.Sessi…src/expand.rs:3080\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: xml\u{a} config: {{ endpoint: "https://x/api", body: "<q>{token}</q>", records_path: r }}\u{a} sink: {{ type: stdout, config: {{}} }}\u{a}src/expand.rs:3107\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a}src/expand.rs:3132 src/expand.rs:4206\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a} dlq:\u{a} sink: { type: jsonl, config: { path:…src/expand.rs:3151 src/expand.rs:5406\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a} state:\u{a} type: file\u{a} config: { path:…src/expand.rs:3168\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a} transforms:\u{a} - type: set\u{a} config:…src/expand.rs:3188 src/expand.rs:3205 src/expand.rs:3221\u{a}version: 1\u{a}auth:\u{a} xml_gateway:\u{a} type: flow\u{a} config:\u{a} steps:\u{a} - request: { url: "https://x/login", method: POST }\u{a} capture: { session_id: "$…src/expand.rs:3242\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: xml\u{a} config:\u{a} base_url: "https://x"\u{a} path: /gw\u{a} body: "<r><sessionid>${session_id}</sessionid></r>"\u{a} si…src/expand.rs:3269\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x?d=${now.date}" } }\u{a} sink: { type: jsonl, config: { path: "out-${now.date}.jsonl" } }\u{a}src/expand.rs:3291\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x, headers: { a: 1 } } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a}matrix:\u{a} - id: users\u{a} …src/expand.rs:3303\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: https://x\u{a} replication_bind: { into: query, name: since, template: "gt ${bookmark}" }\u{a} …src/expand.rs:3371\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: https://x\u{a} async_job: { submit: { url: /jobs }, job_id: "$.id", poll: { url: "/jobs/${job_id…src/expand.rs:3389\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: https://x\u{a} async_job: { submit: { url: /jobs, json: { query: "orders(query: \"${faucet.filte…src/expand.rs:3407\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: https://x\u{a} path: /report\u{a} replication_method: incremental\u{a} replication_key…src/expand.rs:3433\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} api: { type: rest, config: { base_url: https://x, path: /list } }\u{a} sink: { type: jsonl, config: { path: ./o, append: true } }\u{a}matrix:\u{a}…src/expand.rs:3756\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://x/${nobody.id}" } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a}src/expand.rs:3799\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { url: "https://x/${env.foo}" } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a}src/expand.rs:3817\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} users_api: { type: rest, config: { base_url: https://x } }\u{a} sinks:\u{a} archive: { type: jsonl, config: { path: ./out } }\u{a}matrix:…src/expand.rs:4219\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a}matrix:\u{a} - id: users\u{a} source: { config:…src/expand.rs:4244\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} api: { type: rest, config: { base_url: https://x } }\u{a} sinks:\u{a} out: { type: jsonl, config: { path: ./o } }\u{a}matrix:\u{a} - id: x…src/expand.rs:4337\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} users_api: { type: rest, config: { base_url: https://users.example } }\u{a} orders_api: { type: rest, config: { base_url: https://orders.exampl…src/expand.rs:4411https://orders.examplesrc/expand.rs:4433\u{a}version: 1\u{a}delivery: exactly_once\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: stdout, config: {} }\u{a} state:\u{a} type: memory\u{a}…src/expand.rs:4715\u{a}version: 1\u{a}delivery: exactly_once\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink:\u{a} type: postgres\u{a} config:\u{a} connection_url: "pos…src/expand.rs:4824 src/expand.rs:5030\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: stdout, config: {} }\u{a}src/expand.rs:5058\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: jsonl, config: { path: "out.jsonl", write_mode: upsert, key: [id] } }\u{a}src/expand.rs:5122\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: postgres, config: { connection_url: "postgres://x", table_name: t, column_mapp…src/expand.rs:5139 src/expand.rs:5153 src/expand.rs:5203 src/expand.rs:5220 src/expand.rs:5374\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: bigquery, config: { project_id: p, dataset_id: d, table_id: t, auth: { type: a…src/expand.rs:5165\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: jsonl, config: { path: "out.jsonl" } }\u{a}src/expand.rs:5177\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: mongodb, config: { connection_url: "mongodb://x", database: d, collection: c, …src/expand.rs:5189\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink:\u{a} type: postgres\u{a} config:\u{a} connection_url: "postgres://x"\u{a} …src/expand.rs:5235 src/expand.rs:5277\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink:\u{a} type: sqlite\u{a} config:\u{a} connection_url: "sqlite://x"\u{a} ta…src/expand.rs:5254\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: jsonl, config: { path: "out.jsonl", write_mode: overwrite } }\u{a}src/expand.rs:5299\u{a}version: 1\u{a}name: t\u{a}delivery: exactly_once\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: postgres, config: { connection_url: "postgres://x",…src/expand.rs:5318{ type: rabbitmq, config: { url: "amqp://x", queue: q, idle_timeout_secs: 1 } }src/expand.rs:5338{ type: nats, config: { url: "nats://x", subject: s, jetstream_stream: S } }src/expand.rs:5340\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: {source}\u{a} sink: {{ type: postgres, config: {{ connection_url: "postgres://x", table_name: t, column_mapping: auto_map, write_mode: overwr…src/expand.rs:5343\u{a}version: 1\u{a}name: t\u{a}pipeline:\u{a} source: { type: nats, config: { url: "nats://x", subject: s } }\u{a} sink: { type: postgres, config: { connection_url: "postgres://x", table_name: t,…src/expand.rs:5357\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o } }\u{a}resilience:\u{a} poison: { max_row_attempts: 3, ac…src/expand.rs:5389 src/expand.rs:5423\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }\u{a} schema:\u{a} on_drift: evolve\u{a}src/expand.rs:5440\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: postgres, config: {} }\u{a} schema:\u{a} on_drift: quarantine\u{a}src/expand.rs:5464\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: postgres, config: { column_mapping: auto_map } }\u{a} schema:\u{a} on_drift: evolv…src/expand.rs:5489{ type: mysql, config: { connection_url: 'mysql://h/d', table_name: t } }src/expand.rs:5504version: 1\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: https://x }} }}\u{a} sink: {sink}\u{a} schema:\u{a} on_drift: evolve\u{a}src/expand.rs:5509version: 1\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: https://x }} }}\u{a} sink: {upsert}\u{a}src/expand.rs:5515\u{a} type: rest\u{a} config:\u{a} base_url: "https://api.example.com"\u{a} path: "/records?id_from=${partition.start}&id_to=${partition.end}"src/expand.rs:5697\u{a} type: rest\u{a} config:\u{a} base_url: "https://x"\u{a} path: "/r?offset=${partition.offset}&limit=${partition.limit}"src/expand.rs:5806version: 1\u{a}name: g\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ url: "http://x" }} }}\u{a} sink: {{ type: stdout, config: {{}}, attributes: {{ residency: eu }} }}\u{a}{extra}src/governance.rs:451kind: source-template\u{a}name: acme\u{a}description: acme exports\u{a}params:\u{a} region: { type: string, default: us, values: [us, eu] }\u{a}source:\u{a} type: rest\u{a} config:\u{a} base_url…src/hub/bundles.rs:184\u{a}kind: source-template\u{a}name: acme\u{a}description: Acme billing API\u{a}tags: [finance]\u{a}params:\u{a} api_token: { type: string, required: true, secret: true }\u{a}source:\u{a} type: rest…src/hub/catalog.rs:1001https://db.internal/xsrc/hub/catalog.rs:1361postgres://u:hunter2@db/xsrc/hub/catalog.rs:1452\u{a}kind: deployment\u{a}name: prod\u{a}description: Production operations\u{a}params: { dsn: { type: string, secret: true } }\u{a}state: { type: postgres, config: { url: "${param.dsn}" } }\u{a}notif…src/hub/catalog.rs:1481\u{a}kind: deployment\u{a}name: prod\u{a}params: { password: { type: string } }\u{a}state: { type: postgres, config: { url: "postgres://app:hunter2@db:5432/x" } }\u{a}dlq: { sink: { type: http, config…src/hub/catalog.rs:1494\u{a}kind: source-template\u{a}name: spend\u{a}params:\u{a} token: { type: string, required: true, secret: true }\u{a} shared: { type: string, default: a }\u{a}auth:\u{a} spend_oauth: { type: stati…src/hub/compose.rs:843\u{a}kind: deployment\u{a}name: prod\u{a}params:\u{a} state_dir: { type: string, default: ./state }\u{a}state: { type: file, config: { path: "${param.state_dir}" } }\u{a}dlq: { sink: { type: jsonl, c…src/hub/compose.rs:1431\u{a}kind: source-template\u{a}name: pg\u{a}params:\u{a} pg_schema: { type: string, default: public }\u{a} tables:\u{a} type: list\u{a} max_items: 5\u{a} items:\u{a} type: object\u{a} …src/hub/for_each.rs:868\u{a}kind: source-template\u{a}name: pg\u{a}params:\u{a} pg_schema: { type: string, default: public }\u{a} tables: { type: list, items: { type: string }, max_items: 500 }\u{a} shards: { type: list,…src/hub/for_each.rs:895http://src/hub/import/mod.rs:238 src/hub/import/openapi.rs:892https://src/hub/import/mod.rs:238 src/hub/import/openapi.rs:892file:///s.yamlsrc/hub/import/mod.rs:698https://u:p@example.com/openapi.jsonsrc/hub/import/mod.rs:719 src/hub/import/mod.rs:720https://example.com/o.jsonsrc/hub/import/mod.rs:723https://[src/hub/import/mod.rs:724file:///xsrc/hub/import/mod.rs:764 src/hub/import/refs.rs:367 src/serve/load.rs:2986ftp://example.com/xsrc/hub/import/mod.rs:879file:///definitely/not/heresrc/hub/import/mod.rs:884{scheme}://{host}{base}src/hub/import/openapi.rs:1308--server {s}: not an absolute URL (give a full https://… URL or an index into the spec's servers)src/hub/import/openapi.rs:1368https://api.example.invalidsrc/hub/import/openapi.rs:2620file:///spec/api.jsonsrc/hub/import/openapi.rs:2656https://api.example.com/v2src/hub/import/openapi.rs:2729http://api.example.com/v2src/hub/import/openapi.rs:2734https://eu.example.com/v1src/hub/import/openapi.rs:2772https://sandbox.example.comsrc/hub/import/openapi.rs:2794 src/hub/import/openapi.rs:2795https://docs.example.com/spec/openapi.jsonsrc/hub/import/openapi.rs:2801https://docs.example.com/apisrc/hub/import/openapi.rs:2807server https://${env:HOST}/v1src/hub/import/openapi.rs:3586https://${env:H}src/hub/import/openapi.rs:3625https://a.example.comsrc/hub/import/openapi.rs:3772 src/serve/references.rs:270https://{a}.x/{bsrc/hub/import/openapi.rs:3853file:///spec/api.yamlsrc/hub/import/refs.rs:325 src/hub/import/refs.rs:344 src/hub/import/refs.rs:435 src/hub/import/refs.rs:446 src/hub/import/refs.rs:446file:///spec/common.yamlsrc/hub/import/refs.rs:331 src/hub/import/refs.rs:337file:///spec/common.yaml#/csrc/hub/import/refs.rs:334file:///s.jsonsrc/hub/import/refs.rs:378file:///spec/parts/c.yamlsrc/hub/import/refs.rs:439https://example.com/s.yamlsrc/hub/import/refs.rs:442 src/hub/import/refs.rs:450 src/hub/import/refs.rs:451file:///etc/xsrc/hub/import/refs.rs:444https://example.com/v1/openapi.yamlsrc/hub/import/refs.rs:453https://example.com/v1/schemas.yamlsrc/hub/import/refs.rs:456https://api.example.com/v1/openapi.yamlsrc/hub/import/refs.rs:465https://api.example.com:8443/x.yamlsrc/hub/import/refs.rs:475file:///home/u/spec/api.yamlsrc/hub/import/refs.rs:478file:///home/u/spec/parts/a.yamlsrc/hub/import/refs.rs:484 src/hub/import/refs.rs:493file:///etc/passwdsrc/hub/import/refs.rs:501 src/serve/callback.rs:580https://other.example.com/x.yamlsrc/hub/import/refs.rs:504https://github.com/src/hub/mod.rs:84 src/hub/mod.rs:328http://github.com/src/hub/mod.rs:84https://api.github.comsrc/hub/mod.rs:561 src/hub/mod.rs:1178 src/templates/sync/fetch.rs:1103 src/templates/sync/fetch.rs:1286 src/templates/sync/plan.rs:369 src/templates/sync/spec.rs:122kind: source-template\u{a}name: acme\u{a}source: {type: rest, config: {base_url: "https://a", path: /}}\u{a}streams: [{name: t}]\u{a}src/hub/mod.rs:1257 src/hub/remote.rs:729https://x.y/a:bsrc/hub/mod.rs:1307https://github.com/acme/hubsrc/hub/mod.rs:1378https://github.com/acme/hub.git/src/hub/mod.rs:1382https://github.com/acme/hub/tree/dev/catalogsrc/hub/mod.rs:1386https://github.com/acmesrc/hub/mod.rs:1397https://github.com/acme/hub/blob/main/xsrc/hub/mod.rs:1398kind: source-template\u{a}name: acme\u{a}owner: octo\u{a}source: {type: rest, config: {base_url: "https://o", path: /}}\u{a}streams: [{name: t}]\u{a}src/hub/mod.rs:1510http://127.0.0.1:1src/hub/remote.rs:872 src/hub/remote.rs:957 src/hub/remote.rs:1122 src/logship/otlp.rs:803 src/logship/otlp.rs:812 src/logship/session.rs:680 src/logship/spool.rs:1009https://api.examplesrc/hub/remote.rs:1191https://api.example/repos/acme/hub/contents/catalog/hub/source-templates?ref=v1src/hub/remote.rs:1194https://api.example/repos/acme/hub/contents/catalog/hub?ref=v1src/hub/remote.rs:1198\u{a}kind: source-template\u{a}name: spend\u{a}description: Example spend platform\u{a}tags: [finance]\u{a}params:\u{a} client_id: { type: string, required: true, secret: true }\u{a}source:\u{a} typ…src/hub/spec.rs:1060\u{a}kind: source-template\u{a}name: acme\u{a}description: Acme API\u{a}params:\u{a} page_size: { type: int, default: 100 }\u{a}source:\u{a} type: rest\u{a} config:\u{a} base_url: "https://api.e…src/hub/typed.rs:158file:///in.csvsrc/impact/mod.rs:1029file:///a.jsonlsrc/impact/mod.rs:1035 src/impact/mod.rs:1051 src/impact/mod.rs:1435file:///b.jsonlsrc/impact/mod.rs:1057 src/impact/mod.rs:1067 src/impact/mod.rs:1077 src/impact/mod.rs:1171 src/impact/mod.rs:1443file:///c.jsonlsrc/impact/mod.rs:1069file:///{src}src/impact/mod.rs:1114file:///{dst}src/impact/mod.rs:1115[breaking] depth 1 file:///b.jsonlsrc/impact/mod.rs:1185\u{a}version: 1\u{a}vars:\u{a} base: https://api.example.com\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "${vars.base}" } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } …src/interpolate.rs:1543\u{a}version: 1\u{a}vars:\u{a} base: postgres://db/orders\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: {} }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }\u{a}replication:…src/interpolate.rs:1563postgres://db/orderssrc/interpolate.rs:1580\u{a}version: 1\u{a}vars:\u{a} base: https://api.example.com\u{a} users_url: "${vars.base}/v1/users"\u{a}pipeline:\u{a} source: { type: rest, config: { url: "${vars.users_url}" } }\u{a} sink: { …src/interpolate.rs:1587https://api.example.com/v1/userssrc/interpolate.rs:1599\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} users_api:\u{a} type: rest\u{a} config: { base_url: https://api.example.com }\u{a} sinks:\u{a} archive: { type: jsonl, config: { path…src/interpolate.rs:1606https://api.example.com/auditsrc/interpolate.rs:1625\u{a}version: 1\u{a}vars:\u{a} idp_token: topsecret\u{a}auth:\u{a} idp: { type: static, config: { token: "Bearer ${vars.idp_token}" } }\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: …src/interpolate.rs:1823\u{a}version: 1\u{a}auth:\u{a} idp: { type: static, config: { token: "$${vars.literal}" } }\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, co…src/interpolate.rs:1843s3://bucket/dt=${now.date}/part.jsonlsrc/interpolate.rs:1903s3://bucket/dt=2026-03-08/part.jsonlsrc/interpolate.rs:1904version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "http://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}src/livemetrics.rs:470file://{path}src/local_outputs/ledger.rs:497 src/local_outputs/sweep.rs:418file:///tmp/bsrc/local_outputs/ledger.rs:778file:///tmp/out.jsonlsrc/local_outputs/record.rs:124 src/local_outputs/record.rs:169http://c:4318/v1/logssrc/logship/otlp.rs:532 src/logship/otlp.rs:535http://c:4318/v1/logs/src/logship/otlp.rs:534http://{addr}src/logship/otlp.rs:632http://127.0.0.1:1/secret-pathsrc/logship/otlp.rs:780https://g/explore?q={run_id}&p={pipeline}&r={row}&t={tenant}&s={started_at}&e={ended_at}src/logship/record.rs:434https://g/explore?q=r%201&p=a%2Fb&r=x&t=t%26u&s=2026-01-02T03%3A04%3A05.000Z&e=src/logship/record.rs:437version: 1\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: "http://x" }} }}\u{a} sink: {{ type: stdout, config: {{}} }}\u{a}observability:\u{a}{extra}src/logship/session.rs:615version: 1\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: "http://x" }} }}\u{a} sink: {{ type: stdout, config: {{}} }}\u{a}observability:\u{a} otel: {{ export: [{export}] }}\u{a}src/logship/session.rs:770kind: pipeline\u{a}version: 1\u{a}name: gated\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: "https://example.com"\u{a} path: /rows\u{a} sink:\u{a} type: j…src/mcp/tools.rs:2184 src/serve/handlers/templates.rs:2035https://events.pagerduty.com/v2/enqueuesrc/notify/channels.rs:17at http://secretsrc/notify/channels.rs:138http://127.0.0.1:1/services/T000/B000/SECRETTOKENsrc/notify/channels.rs:147http://xsrc/notify/dispatch.rs:417 src/notify/dispatch.rs:794 src/notify/render.rs:159 src/notify/spec.rs:487 src/secrets/vault.rs:158http://127.0.0.1:0/enqueuesrc/notify/dispatch.rs:540http://127.0.0.1:1/xsrc/notify/dispatch.rs:648HTTP error for url (https://api.example.com/v1?api_key={secret})src/notify/event.rs:510http://hsrc/notify/spec.rs:414http://ssrc/notify/spec.rs:416 src/notify/spec.rs:417\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "http://x" } }\u{a} sink: { type: stdout, config: {} }\u{a}observability:\u{a} otel: { endpoint: "http://c:4317" }\u{a}src/obs.rs:210https://accounts.example.comsrc/params/bind.rs:1509https://api.example.com/acme/eventssrc/params/bind.rs:1711https://x/<param>src/params/bind.rs:1980https://api/x?from=10&to=19src/partition/plan.rs:318redis://src/pipeline_state/ops.rs:1085rediss://src/pipeline_state/ops.rs:1085 src/state.rs:206postgres://u@h/dbsrc/pipeline_state/ops.rs:2007REDIS://h:6379src/pipeline_state/ops.rs:2012{type: redis, config: {url: 'redis://h', namespace: n}}src/pipeline_state/ops.rs:2024version: 1\u{a}name: topo\u{a}pipeline:\u{a} sources: { src: { type: csv, config: { path: in.csv } } }\u{a} sinks:\u{a} a: { type: jsonl, config: { path: a.jsonl } }\u{a} b: { type: sqlite, co…src/pipeline_state/target.rs:312version: 1\u{a}name: m\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: { connection_url: "postgres://u@h/d", slot_name: s, publication: p } }\u{a} sink: { type: jsonl, config: { path: out.j…src/pipeline_state/target.rs:355version: 1\u{a}name: m\u{a}pipeline:\u{a} source: {{ type: postgres-cdc, config: {{ connection_url: "postgres://u@h/d", slot_name: s, publication: p }} }}\u{a} sink: {{ type: sqlite, config: {{ data…src/pipeline_state/target.rs:376source: { type: postgres, config: { connection_url: "postgres://x", query: "SELECT * FROM t" } }src/replication/compiled.rs:305 src/replication/compiled.rs:353\u{a}version: 1\u{a}name: mirror\u{a}pipeline:\u{a} source: { type: dynamodb, config: { table_name: orders, mode: streams, idle_termination_secs: 5 } }\u{a} sink: { type: postgres, config: { conne…src/replication/compiled.rs:374\u{a}version: 1\u{a}name: mirror\u{a}pipeline:\u{a} source: { type: oracle-cdc, config: { host: db, service_name: ORCLPDB1, username: u, password: p, tables: [APP.ORDERS] } }\u{a} sink: { type: po…src/replication/compiled.rs:426\u{a}version: 1\u{a}name: shop\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: { connection_url: "postgres://x", slot_name: s, publication_name: p } }\u{a} sink: { type: postgres, config:…src/replication/compiled.rs:459type: postgres, config: { connection_url: "postgres://x", querysrc/replication/compiled.rs:513type: rest, config: { url: "https://a", querysrc/replication/compiled.rs:514sink: { type: postgres, config: { connection_url: "postgres://y", column_mapping: auto_map } }src/replication/compiled.rs:527{ type: postgres-cdc, config: { connection_url: "postgres://x", slot_name: s, publication_name: p } }src/replication/compiled.rs:541 src/replication/compiled.rs:547 src/replication/compiled.rs:559{ type: mongodb-cdc, config: { connection_uri: "mongodb://m", scope: { type: collection, database: d, collection: c } } }src/replication/compiled.rs:548{{ type: mongodb-cdc, config: {{ connection_uri: "mongodb://m"{scope} }} }}src/replication/compiled.rs:560{ type: postgres, config: { connection_url: "postgres://x", query: "SELECT 1" } }src/replication/compiled.rs:563{{ type: mongodb, config: {{ connection_uri: "mongodb://m", database: {db}, collection: c }} }}src/replication/compiled.rs:564\u{a}version: 1\u{a}name: m\u{a}pipeline:\u{a} source: { type: postgres, config: { connection_url: "postgres://x", query: "SELECT 1" } }\u{a} sink: { type: postgres, config: { connection_url: "pos…src/replication/multi.rs:1232connect postgres://u:pw@h/d failed: mirror-s3cr3t-value {}src/replication/multi_state.rs:708\u{a}mode: snapshot_then_cdc\u{a}snapshot:\u{a} source:\u{a} type: postgres\u{a} config: { connection_url: "postgres://x", query: "SELECT * FROM orders" }\u{a}src/replication/spec.rs:208version: 1\u{a}name: one\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: https://a }} }}\u{a} sink: {{ type: stdout, config: {{}} }}\u{a} state: {{ type: file, config: {{ path: {} }}…src/replication/status.rs:500postgres://ssrc/replication/tables.rs:506mysql://u:p@h:3306/shop?ssl=1src/replication/tables.rs:712mysql://h:3306/src/replication/tables.rs:715mysql://h:3306src/replication/tables.rs:716fake://tsrc/rollback/mod.rs:746 src/rollback/mod.rs:802[package]\u{a}name = "{crate_name}"\u{a}version = "1.0.0"\u{a}edition = "2024"\u{a}rust-version = "{MSRV}"\u{a}license = "MIT OR Apache-2.0"\u{a}repository = "https://github.com/your-org/{crate_name}"…src/scaffold.rs:171#![cfg_attr(docsrs, feature(doc_cfg))]\u{a}\u{a}//! # {crate_name}\u{a}//!\u{a}//! {name} {role} connector for the [faucet-stream](https://docs.rs/faucet-stream)\u{a}//! ecosystem. Generated by `fauce…src/scaffold.rs:217# {crate_name}\u{a}\u{a}{name} {role} connector for the [faucet-stream](https://github.com/faucet-hq/faucet-stream)\u{a}ecosystem. Generated by `faucet new connector`.\u{a}\u{a}## Usage from a pipelin…src/scaffold.rs:504[package]\u{a}name = "{common}"\u{a}version = "1.0.0"\u{a}edition = "2024"\u{a}rust-version = "{MSRV}"\u{a}license = "MIT OR Apache-2.0"\u{a}repository = "https://github.com/your-org/{common}"\u{a}des…src/scaffold.rs:539# {common}\u{a}\u{a}Shared config types for the {name} source/sink pair of the\u{a}[faucet-stream](https://github.com/faucet-hq/faucet-stream) ecosystem. Generated\u{a}by `faucet new connector --with-…src/scaffold.rs:567https://{vault}.vault.azure.net/src/secrets/azure_kv.rs:191https://my-vault.vault.azure.net/src/secrets/azure_kv.rs:334https://secretmanager.googleapis.com/v1/{reference}:accesssrc/secrets/gcp_sm.rs:72\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x, auth: { type: bearer, config: { token: "${vault:secret/data/app#token}" } } } }\u{a} sink: { type: jsonl, co…src/secrets/mod.rs:692\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }\u{a} masking:\u{a} key: "${vault:secret/data/…src/secrets/mod.rs:711\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }\u{a}execution: { max_concurrent: 1 }\u{a}matrix:…src/secrets/mod.rs:736\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x, token: "${vault:secret/data/app#token}" } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl } }\u{a} ma…src/secrets/mod.rs:764\u{a}version: 1\u{a}name: m\u{a}pipeline:\u{a} source: { type: postgres-cdc, config: { connection_url: "postgres://h/db", slot_name: s, publication: p } }\u{a} sink: { type: jsonl, config: { path: .…src/secrets/mod.rs:792\u{a}version: 1\u{a}vars:\u{a} shared_token: "${vault:secret/data/app#token}"\u{a}auth:\u{a} idp: { type: static, config: { token: "${vault:secret/data/idp#token}" } }\u{a}pipeline:\u{a} source: { …src/secrets/mod.rs:869\u{a}version: 1\u{a}vars:\u{a} v: "${aws-sm:prod/api#key}"\u{a}auth:\u{a} idp: { type: static, config: { token: "${vault:secret/data/idp#token}" } }\u{a}pipeline:\u{a} source: { type: rest, config:…src/secrets/mod.rs:893open 'postgres://app:pw@db:5432/x' failed (s3cr3t-874-value); retry https://h/api?api_key=k1&x=1 and mysql://u:p2@m/ysrc/secrets/registry.rs:631postgres://db:5432/xsrc/secrets/registry.rs:638mysql://m/ysrc/secrets/registry.rs:639at end url=s3://b/ksrc/secrets/registry.rs:642 src/secrets/registry.rs:642set VAULT_ADDR (e.g. https://vault.example.com:8200)src/secrets/vault.rs:23https://vault.example.com:8200/src/secrets/vault.rs:255https://vault.example.com:8200src/secrets/vault.rs:261https://vsrc/secrets/vault.rs:292\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} hibob: { type: rest, config: { base_url: https://api.hibob.com } }\u{a} sinks:\u{a} wh: { type: jsonl, config: { path: ./o, append: true } }…src/select.rs:859\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} api: { type: rest, config: { base_url: https://x } }\u{a} sinks:\u{a} wh: { type: jsonl, config: { path: ./o, append: true } }\u{a}matrix:\u{a}…src/select.rs:1021 src/select.rs:1042 src/select.rs:1095 src/select.rs:1124 src/select.rs:1164\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o, append: true } }\u{a}src/select.rs:1191\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x } }\u{a} sink: { type: jsonl, config: { path: ./o, append: true } }\u{a}matrix:\u{a} - { id: a }\u{a} - { i…src/select.rs:1211http://[::ffff:169.254.169.254]/latestsrc/serve/callback.rs:479http://[::ffff:a9fe:a9fe]/xsrc/serve/callback.rs:480http://[fe80::1]/xsrc/serve/callback.rs:481http://localhost:9/xsrc/serve/callback.rs:491 src/serve/callback.rs:564http://127.0.0.1:9/src/serve/callback.rs:496http://169.254.169.254/src/serve/callback.rs:501 src/serve/references.rs:246 src/serve/runner.rs:2504http://no-such-host.invalid/src/serve/callback.rs:508http://[fd00:ec2::254]/latest/api/tokensrc/serve/callback.rs:519http://[::ffff:100.100.100.200]/xsrc/serve/callback.rs:520http://100.100.100.200/latest/meta-data/src/serve/callback.rs:521http://[fd00:ec2::253]/xsrc/serve/callback.rs:526http://127.0.0.1:8080/v1/templates/crmsrc/serve/callback.rs:532http://localhost/xsrc/serve/callback.rs:533http://api.localhost/xsrc/serve/callback.rs:534http://0.0.0.0/xsrc/serve/callback.rs:535http://10.1.2.3/xsrc/serve/callback.rs:536 src/serve/callback.rs:559http://172.16.0.1/xsrc/serve/callback.rs:537http://192.168.1.1/xsrc/serve/callback.rs:538http://100.64.0.1/xsrc/serve/callback.rs:539http://[::1]/xsrc/serve/callback.rs:540http://[::]/xsrc/serve/callback.rs:541http://[fd12::1]/xsrc/serve/callback.rs:542http://[::ffff:10.0.0.1]/xsrc/serve/callback.rs:543https://caller.example/hooksrc/serve/callback.rs:553 src/serve/callback.rs:575 src/serve/callback.rs:609http://8.8.8.8/xsrc/serve/callback.rs:557http://127.0.0.1:9/xsrc/serve/callback.rs:567http://[fd00:ec2::254]/xsrc/serve/callback.rs:569gopher://x/src/serve/callback.rs:580ftp://x/src/serve/callback.rs:580http://169.254.169.254/latest/meta-data/src/serve/callback.rs:590http://metadata.google.internal/computeMetadata/v1/src/serve/callback.rs:591http://[fe80::1]/src/serve/callback.rs:592http://127.0.0.1:8080/cbsrc/serve/callback.rs:603https://elsewhere.example/hooksrc/serve/callback.rs:610http://169.254.169.254/xsrc/serve/callback.rs:620https://x.example/hsrc/serve/callback.rs:628 src/serve/callback.rs:638 src/serve/callback.rs:646 src/serve/callback.rs:654 src/serve/callback.rs:663 src/serve/callback.rs:671 src/serve/callback.rs:698 src/serve/callback.rs:717notifications:\u{a} - name: log\u{a} on: [change_requested]\u{a} channel:\u{a} type: webhook\u{a} config:\u{a} url: http://127.0.0.1:9/hook\u{a}src/serve/changes/mod.rs:2167unrecognised --history '{u}': use a postgres:// URL or sqlite:<path>src/serve/config.rs:336--cluster requires a persistent --history backend (postgres://… or sqlite:…); the in-memory store is single-processsrc/serve/config.rs:383endpoint: http://collector:4318\u{a}protocol: http\u{a}export: [traces]\u{a}headers: { authorization: "Bearer ${env:FAUCET_TEST_SERVE_OTEL_TOKEN}" }\u{a}src/serve/config.rs:562http://collector:4318src/serve/config.rs:567 src/serve/config.rs:583endpoint: http://c:4317\u{a}prometheus: {}\u{a}src/serve/config.rs:572postgres://localhost/dbsrc/serve/config.rs:883postgresql://localhost/dbsrc/serve/config.rs:889mysql://localhost/dbsrc/serve/config.rs:923connect postgres://svc:hunter2@db/x failedsrc/serve/error.rs:209file://{}src/serve/handlers/preview.rs:353file:///out.jsonlsrc/serve/handlers/preview.rs:628 src/serve/handlers/preview.rs:677 src/serve/handlers/preview.rs:721 src/serve/handlers/preview.rs:882csv://./other.csvsrc/serve/history/catalog.rs:815x://dsrc/serve/history/catalog.rs:922 src/serve/history/catalog.rs:930a://1src/serve/history/catalog.rs:955 src/serve/history/catalog.rs:964b://2src/serve/history/catalog.rs:955 src/serve/history/catalog.rs:964csv://asrc/serve/history/catalog.rs:999 src/serve/history/catalog.rs:1054 src/serve/history/catalog.rs:1079csv://bsrc/serve/history/catalog.rs:1000 src/serve/history/catalog.rs:1055CSV://src/serve/history/catalog.rs:1022csv://csrc/serve/history/catalog.rs:1056csv://a.csvsrc/serve/history/catalog.rs:1160 src/serve/history/catalog.rs:1169 src/serve/history/catalog.rs:1187csv://b.csvsrc/serve/history/catalog.rs:1161 src/serve/history/catalog.rs:1170jsonl://out.jsonlsrc/serve/history/catalog.rs:1163 src/serve/history/catalog.rs:1171 src/serve/history/catalog.rs:1188url:https://x:8080src/serve/history/labels.rs:166https://x:8080src/serve/history/labels.rs:169 src/serve/history/labels.rs:261file:///same/path.jsonlsrc/serve/history/memory.rs:2412postgres://u:p@127.0.0.1:1/xsrc/serve/history/postgres.rs:72sqlite://{}/h.dbsrc/serve/history/sqlite.rs:81 src/serve/runner.rs:3275sqlite://h.db?nonsense=1src/serve/history/sqlite.rs:134sqlite://no/such/dir/h.dbsrc/serve/history/sqlite.rs:153file://src/serve/load.rs:620://xsrc/serve/load.rs:24721http://xsrc/serve/load.rs:2473a b://xsrc/serve/load.rs:2474postgres+ssl://h/dbsrc/serve/load.rs:2475sqlite:///var/h.db?mode=rwcsrc/serve/load.rs:2933postgres://xsrc/serve/load.rs:2937s3://b/ksrc/serve/load.rs:2988version: 1\u{a}pipeline:\u{a} sources:\u{a} x: { type: rest, config: { url: "http://h", path: /users } }\u{a} sink: { type: stdout, config: {} }\u{a}matrix:\u{a} - id: r\u{a} source: { ref: x…src/serve/load.rs:3132https://${parent.host}/v1src/serve/load.rs:3668https://api.example.com/items/${parent.id}src/serve/load.rs:3679https://api.example.com/${now.date}src/serve/load.rs:3680http://169.254.169.254/latestsrc/serve/load.rs:3849 src/serve/triggers/enqueue.rs:737 src/serve/triggers/enqueue.rs:741 src/serve/triggers/enqueue.rs:761http://169.254.169.254/latest/src/serve/references.rs:225http://a.example.comsrc/serve/references.rs:271version: 1\u{a}name: m\u{a}matrix:\u{a} - id: a\u{a} - id: b\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://localhost/x" } }\u{a} sink: { type: stdout, config: {} }\u{a}src/serve/runner.rs:3361version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://localhost/x" } }\u{a} sink: { type: stdout, config: {} }\u{a}src/serve/runner.rs:3415version: 1\u{a}pipeline:\u{a} source: { type: postgres, config: { connection_url: "postgres://x", query: "select 1" } }\u{a} sink: { type: postgres, config: { connection_url: "postgres://y", table_n…src/serve/runner.rs:3438https://idp.example/authorizesrc/serve/tenants/connect.rs:521https://idp.example/tokensrc/serve/tenants/connect.rs:522 src/serve/tenants/mod.rs:2320https://faucet.example/src/serve/tenants/connect.rs:528https://app.examplesrc/serve/tenants/connect.rs:529 src/serve/tenants/connect.rs:536https://b.example/x/src/serve/tenants/connect.rs:529https://app.example/settings?x=1src/serve/tenants/connect.rs:537https://app.example?x=1src/serve/tenants/connect.rs:538https://b.example/x/donesrc/serve/tenants/connect.rs:539https://app.example.evil/src/serve/tenants/connect.rs:540https://b.example/xysrc/serve/tenants/connect.rs:541https://faucet.example/v1/connect/callbacksrc/serve/tenants/connect.rs:550 src/serve/tenants/connect.rs:563ftp://x/ysrc/serve/tenants/connect.rs:607version: 1\u{a}providers:\u{a} - name: crm\u{a} authorize_url: https://i/a\u{a} token_url: https://i/t\u{a} client_id: c\u{a} client_secret: s\u{a} redirect_base: https://f\u{a} all…src/serve/tenants/connect.rs:639version: 1\u{a}providers:\u{a} - name: crm\u{a} authorize_url: https://i/a\u{a} token_url: https://i/t\u{a} client_id: c\u{a} client_secret: ${{file:{}}}\u{a} redirect_base: https://f…src/serve/tenants/connect.rs:658https://app.example/cb?a=1src/serve/tenants/connect.rs:676https://app.example/cb?a=1&status=oksrc/serve/tenants/connect.rs:677https://i/new-tokensrc/serve/tenants/mod.rs:1875rt-very-secret-1 pw-very-secret-2 visible-client https://idp.example/tokensrc/serve/tenants/mod.rs:2315version: 1\u{a}triggers:\u{a} - name: q\u{a} type: queue_depth\u{a} config: ./x.yaml\u{a} threshold: 0\u{a} queue: { type: redis, url: "redis://x", key: k }\u{a}src/serve/triggers/compiled.rs:447queue_depth\u{a} queue: { type: redis, url: "redis://x", key: k }src/serve/triggers/compiled.rs:462path: "s3://bucket/${trigger.object_key}"\u{a}src/serve/triggers/context.rs:755url: "https://${trigger.header.x-region}.api.example/v1"\u{a}src/serve/triggers/context.rs:775listing s3://k:secret@bucket failedsrc/serve/triggers/health.rs:224version: 1\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config: {url: 'http://x'}\u{a} sink:\u{a} type: stdout\u{a} config: {}\u{a}src/serve/triggers/mod.rs:289redis://127.0.0.1:{port}src/serve/triggers/queue_depth.rs:348\u{a}version: 1\u{a}triggers:\u{a} - name: hook\u{a} type: webhook\u{a} config: { pipeline: { sources: {}, sinks: {} } }\u{a} dedupe_header: Idempotency-Key\u{a} debounce_secs: 30\u{a} -…src/serve/triggers/spec.rs:386version: 1\u{a}triggers:\u{a} - name: obj\u{a} type: object_arrival\u{a} enabled: true\u{a} config: ./load.yaml\u{a} run: { name: r, timeout_secs: 10 }\u{a} store: { type: s3, bucket: …src/serve/triggers/spec.rs:469version: 1\u{a}name: o\u{a}pipeline:\u{a} source: { type: csv, config: { path: a } }\u{a} sink: { type: sqlite, config: { database_url: 'sqlite://x.db', table_name: t, write_mode: overwrite } }\u{a}…src/status/tests.rs:356https://faucet-hq.github.io/faucet-stream/cookbook/templates.html#template-tests-and-labelssrc/template_tests/gate.rs:22kind: pipeline\u{a}version: 1\u{a}name: bundle-fixture\u{a}params:\u{a} out:\u{a} type: string\u{a} default: ./out.jsonl\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} …src/template_tests/run.rs:210version: 1\u{a}name: suite-fixture\u{a}params:\u{a} tenant:\u{a} type: string\u{a} required: true\u{a} region:\u{a} type: string\u{a} default: us\u{a} values: [us, eu]\u{a} page_size…src/template_tests/runner.rs:848kind: pipeline\u{a}version: 1\u{a}name: {name}\u{a}params:\u{a} region:\u{a} type: string\u{a} default: us\u{a} values: [us, eu]\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config…src/templates/bundle.rs:785kind: source-template\u{a}name: acme\u{a}description: acme\u{a}source:\u{a} type: rest\u{a} config: {{ base_url: "https://example.com" }}\u{a}streams:\u{a} - name: orders\u{a} source: {{ config:…src/templates/bundle.rs:1311template store '{other}' is not recognised — expected 'memory', 'sqlite:<path>', or a 'postgres://…' URLsrc/templates/store.rs:1807version: 1\u{a}name: tenant-sync\u{a}params:\u{a} tenant_id: { required: true, description: Tenant to sync }\u{a} since: { default: "1970-01-01" }\u{a} page: { type: int, default: 100 }\u{a}pipelin…src/templates/store.rs:1845\u{a}version: 1\u{a}name: tenant-sync\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x", path: /e } }\u{a} transforms:\u{a} - type: set\u{a} config: { fields: { a: 1 }…src/templates/store.rs:1919\u{a}version: 1\u{a}name: tenant-sync\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x", path: /e } }\u{a} sink: { type: jsonl, config: { path: { nested: wrong } } }\u{a}src/templates/store.rs:1948version: 1\u{a}name: env-template\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://x", path: "/${env:FAUCET_TPL_REGION}" } }\u{a} sink: { type: jsonl, config: { path: ./o.jsonl …src/templates/store.rs:2413version: 1\u{a}name: secret-template\u{a}params:\u{a} api_token: { required: true, secret: true }\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: https://api.exampl…src/templates/store.rs:2493kind: source-template\u{a}name: leaky\u{a}source:\u{a} type: rest\u{a} config:\u{a} base_url: https://api.example.com\u{a} auth: { type: bearer, config: { token: hunter2secretvalue } }\u{a}str…src/templates/store.rs:2936kind: deployment\u{a}name: leaky\u{a}state: { type: postgres, config: { url: "postgres://u:hunter2@db/x" } }\u{a}src/templates/store.rs:3272version: 1\u{a}name: t\u{a}pipeline:\u{a} source: {type: rest, config: {base_url: "https://x", path: /e}}\u{a} sink: {type: stdout, config: {}}\u{a}tests:\u{a} suite:\u{a} auto: { defaults_basel…src/templates/sync/apply.rs:254 src/templates/sync/mod.rs:684s3://{}src/templates/sync/fetch.rs:789gs://{}src/templates/sync/fetch.rs:802azure://{}src/templates/sync/fetch.rs:817https://ghe.example/api/v3/src/templates/sync/fetch.rs:1112https://ghe.example/api/v3/repos/acme/t/contents/templatessrc/templates/sync/fetch.rs:1117https://ghe.example/api/v3/repos/acme/t/contents/templates/x.yamlsrc/templates/sync/fetch.rs:1121https://ghe.example/api/v3/repos/acme/t/contents/x.yamlsrc/templates/sync/fetch.rs:1131http://localhost:9000src/templates/sync/fetch.rs:1253s3://bsrc/templates/sync/fetch.rs:1256gs://gsrc/templates/sync/fetch.rs:1265azure://csrc/templates/sync/fetch.rs:1275{"version":1,"pipeline":{"source":{"type":"rest","config":{"base_url":"https://y","path":"/p"}},"sink":{"type":"stdout","config":{}}}}src/templates/sync/mod.rs:759 src/templates/sync/mod.rs:828version: 1\u{a}name: a\u{a}pipeline:\u{a} source: {type: rest, config: {base_url: "https://x", path: /e}}\u{a} sink: {type: stdout, config: {}}\u{a}src/templates/sync/plan.rs:358file:///tmp/o.jsonlsrc/topology.rs:2642 src/topology.rs:2674 src/topology.rs:2700 src/topology.rs:2712file:///tmp/a.csvsrc/topology.rs:2672 src/topology.rs:2698 src/topology.rs:2712file:///tmp/b.csvsrc/topology.rs:2673 src/topology.rs:2698{ type: sqs, config: { queue_url: "https://q" } }src/topology.rs:2969bq://p/{pipeline}src/usage/model.rs:483bq://p/bsrc/usage/model.rs:631version: 1\u{a}budget: { max_records: 5 }\u{a}resilience: { retry: { max_attempts: 2 } }\u{a}pipeline:\u{a} source: { type: rest, config: { url: "http://x" } }\u{a} sink: { type: stdout, config: {} …src/verify/mod.rs:1156
info url_literal test 292
http://127.0.0.1:9/tokentests/auth_legacy_persist.rs:12sqlite://{path}?mode=rwctests/backfill_end_to_end.rs:66 tests/serve_backfill.rs:117sqlite://{src}tests/backfill_end_to_end.rs:72sqlite://{dst}tests/backfill_end_to_end.rs:92 tests/backfill_end_to_end.rs:199\u{a}version: 1\u{a}name: bf\u{a}pipeline:\u{a} source:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://{src}"\u{a} query: >-\u{a} SELECT id, day, amount FROM event…tests/backfill_end_to_end.rs:105 tests/backfill_end_to_end.rs:499\u{a}version: 1\u{a}name: bf\u{a}pipeline:\u{a} source:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://{src}"\u{a} query: "SELECT id, day, amount FROM events"\u{a} sink:…tests/backfill_end_to_end.rs:255 tests/backfill_end_to_end.rs:310sqlite://{}?mode=rwctests/batch_atomicity.rs:123 tests/dlq_replay_end_to_end.rs:284 tests/executor_scope.rs:74 tests/partitioned_run.rs:232 tests/scoped_cleanup.rs:137 tests/scoped_cleanup.rs:168 tests/scoped_cleanup.rs:197 tests/scoped_cleanup.rs:225 tests/scoped_cleanup.rs:253 tests/scoped_cleanup.rs:276 tests/serve_template_for_each.rs:19 tests/serve_verify_rollback.rs:177 tests/serve_verify_rollback.rs:178 tests/serve_verify_rollback.rs:493 tests/serve_verify_rollback.rs:494 tests/serve_verify_rollback.rs:538 tests/serve_verify_rollback.rs:539 tests/verify_rollback.rs:134 tests/verify_rollback.rs:135 tests/verify_rollback.rs:744 tests/verify_rollback.rs:1230 tests/verify_rollback.rs:1231version: 1\u{a}name: upsert_ok\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: http://x\u{a} sink:\u{a} type: postgres\u{a} config:\u{a} connection_url: …tests/cli_end_to_end.rs:383version: 1\u{a}name: upsert_bad\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: http://x\u{a} sink:\u{a} type: jsonl\u{a} config:\u{a} path: out.jsonl…tests/cli_end_to_end.rs:419http://localhost:5000/api/v1/lineagetests/cli_end_to_end.rs:831postgres://u:p@localhost/dbtests/cli_end_to_end.rs:832postgres://u:p@localhost/srctests/cli_end_to_end.rs:834postgres://u:p@localhost/dsttests/cli_end_to_end.rs:835https://api.example.comtests/cli_end_to_end.rs:847 tests/templates_end_to_end.rs:64 tests/templates_end_to_end.rs:77https://auth.example.com/oauth/tokentests/cli_end_to_end.rs:848\u{a}version: 1\u{a}name: queue_preview\u{a}pipeline:\u{a} source:\u{a} type: sqs\u{a} config:\u{a} queue_url: "http://127.0.0.1:1/000000000000/orders"\u{a} region: us-east-1\u{a} …tests/destructive_reads.rs:12version: 1\u{a}name: replay\u{a}resilience: { retry: { max_attempts: 1 }, circuit_breaker: { consecutive_failures: 1, cooldown_secs: 1 } }\u{a}pipeline:\u{a} source: { type: csv, config: { path: /dev…tests/dlq_cmd.rs:240version: 1\u{a}name: replay\u{a}pipeline:\u{a} source: {{ type: csv, config: {{ path: /dev/null }} }}\u{a} sink: {{ type: sqlite, config: {{ database_url: "sqlite://{}", table_name: t, column_mappin…tests/dlq_replay_end_to_end.rs:326version: 1\u{a}name: replay\u{a}pipeline:\u{a} source:\u{a} type: csv\u{a} config: {{ path: /dev/null }}\u{a} complete_for: {{ scope: {{ acct: 7 }}, on_missing: delete }}\u{a} sink: {{ type…tests/dlq_replay_end_to_end.rs:353postgres://user:pass@localhost:5432/dbtests/docs_config_blocks.rs:117mysql://user:pass@localhost:3306/dbtests/docs_config_blocks.rs:119https://placeholder.invalidtests/docs_config_blocks.rs:121a: postgres://user:pass@localhost:5432/db\u{a}b: 5432\u{a}c: placeholder\u{a}d: ${vault:x#y}\u{a}e: $${literal}\u{a}f: placeholder\u{a}g: mysql://user:pass@localhost:3306/db\u{a}h: https://placeholder…tests/docs_config_blocks.rs:247http://127.0.0.1:9tests/doctor.rs:74 tests/doctor.rs:91 tests/serve_tenants.rs:1093 tests/serve_tenants.rs:1155 tests/serve_tenants.rs:1311 tests/serve_tenants.rs:1392\u{a}version: 1\u{a}name: sheets\u{a}auth:\u{a} google:\u{a} type: google_service_account\u{a} config:\u{a} key_file: "{key}"\u{a} scopes: ["https://www.googleapis.com/auth/spreadshee…tests/google_sa_auth_test.rs:50http://127.0.0.1:1tests/hub_cli.rs:729https://elsewhere.example.com/thing.yamltests/hub_import.rs:439\u{a}kind: source-template\u{a}name: acme\u{a}description: Acme items API\u{a}params:\u{a} page_size: {{ type: {page_size_type}, default: 100 }}\u{a}source:\u{a} type: rest\u{a} config:\u{a} bas…tests/hub_typed_validation.rs:20\u{a}version: 1\u{a}kind: pipeline\u{a}params:\u{a} page_size: { type: int, default: 100 }\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: "https://api.example.com"…tests/hub_typed_validation.rs:158datasets:\u{a} - dataset: "file://{}"\u{a} owners: [team-a]\u{a} consumers:\u{a} - {{ name: raw-export, kind: export, columns: [amount] }}\u{a}tests/impact_e2e.rs:69version: 1\u{a}name: t\u{a}lineage:\u{a} namespace: test\u{a} transport: {{ type: http, config: {{ url: "http://127.0.0.1:1/api/v1/lineage", timeout_secs: 1 }} }}\u{a}pipeline:\u{a} source: {{ type…tests/lineage_run.rs:76postgres://postgres@127.0.0.1:{port}/postgrestests/mirror_tables.rs:42 tests/replication.rs:36 tests/status_lag.rs:35mongodb://127.0.0.1:{port}/?directConnection=truetests/mirror_tables_mongodb.rs:29mysql://root@127.0.0.1:{port}/testtests/mirror_tables_mysql.rs:35 tests/sql_incremental.rs:133\u{a}version: 1\u{a}name: probed\u{a}pipeline:\u{a} source:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://{db}?mode=rwc"\u{a} query: "SELECT 1 AS id WHERE ${{partition.s…tests/partitioned_run.rs:330http://localhost:1/tests/registry_capability_parity.rs:177gid://example/BulkOperation/1tests/rest_bulk_topology.rs:19{"id":"gid://example/Order/1","name":"#1"}\u{a}tests/rest_bulk_topology.rs:41{"id":"gid://example/LineItem/11","__parentId":"gid://example/Order/1"}\u{a}tests/rest_bulk_topology.rs:42{"id":"gid://example/LineItem/12","__parentId":"gid://example/Order/1"}\u{a}tests/rest_bulk_topology.rs:43{"id":"gid://example/Order/2","name":"#2"}\u{a}tests/rest_bulk_topology.rs:44{"id":"gid://example/LineItem/21","__parentId":"gid://example/Order/2"}\u{a}tests/rest_bulk_topology.rs:45gid://example/Order/1tests/rest_bulk_topology.rs:157gid://example/Order/2tests/rest_bulk_topology.rs:158http://127.0.0.1:{port}/hooks/a%20btests/rest_fanout_path_encode.rs:121\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: csv\u{a} config: { path: "./x.csv" }\u{a} complete_for:\u{a} scope: {}\u{a} on_missing: delete\u{a} sink:\u{a} type: sqlit…tests/scoped_cleanup.rs:307\u{a}version: 1\u{a}pipeline:\u{a} source: { type: csv, config: { path: "./x.csv" } }\u{a} sink:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://x.db"\u{a} table_name: t…tests/scoped_cleanup.rs:384\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: csv\u{a} config: { path: "./x.csv" }\u{a} complete_for:\u{a} scope: { contact_id: 7 }\u{a} on_missing: delete\u{a} sink:\u{a}…tests/scoped_cleanup.rs:407\u{a} sink:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://x.db"\u{a} table_name: t\u{a} column_mapping: auto_map\u{a} write_mode: upsert\u{a} key: [id]…tests/scoped_cleanup.rs:439\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: sqs\u{a} config: {{ queue_url: "https://sqs.us-east-1.amazonaws.com/1/q", max_messages: 10 }}\u{a} complete_for:\u{a} scope: {{ gro…tests/scoped_cleanup.rs:503type: websocket\u{a} config: { url: "wss://example.com/feed", max_messages: 10 }tests/scoped_cleanup.rs:522\u{a}version: 1\u{a}pipeline:\u{a} sources:\u{a} parents: {{ type: csv, config: {{ path: ./p.csv }} }}\u{a} child:\u{a} type: csv\u{a} config: {{ path: "./c-${{p.id}}.csv" }}\u{a} …tests/scoped_cleanup.rs:547\u{a}version: 1\u{a}pipeline:\u{a} source:\u{a} type: file\u{a} config: {{ path: "./x.csv", incremental: {{ by: mtime }} }}\u{a} sink:\u{a} type: sqlite\u{a} config:\u{a} database_u…tests/scoped_cleanup.rs:591type: sqlite\u{a} config: { database_url: "sqlite://x.db", table_name: t, column_mapping: auto_map, write_mode: append }tests/scoped_cleanup.rs:651type: sqlite\u{a} config: { database_url: "sqlite://x.db", table_name: t, column_mapping: auto_map, write_mode: upsert, key: [pk] }tests/scoped_cleanup.rs:662postgres://u:store-pass-9@db/xtests/secret_output.rs:20\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x, auth: { type: bearer, config: { token: "${aws-sm:prod/faucet#token}" } } } }\u{a} sink: { type: jsonl, confi…tests/secrets_aws_sm.rs:21\u{a}version: 1\u{a}pipeline:\u{a} source: {{ type: rest, config: {{ base_url: https://x, auth: {{ type: bearer, config: {{ token: "${{vault:secret/data/app#token}}" }} }} }} }}\u{a} sink: {{ type…tests/secrets_validate.rs:14\u{a}version: 1\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: https://x, auth: { type: bearer, config: { token: "${vault:secret/data/faucet/api#token}" } } } }\u{a} sink: { type: js…tests/secrets_vault.rs:20http://{listen}tests/serve_backfill.rs:81 tests/serve_error_redaction.rs:48 tests/serve_http_hardening.rs:70 tests/serve_skeleton.rs:78\u{a}version: 1\u{a}name: orders\u{a}pipeline:\u{a} source:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://{src_db}"\u{a} query: >-\u{a} SELECT id, day FROM events…tests/serve_backfill.rs:97s3://b/exports/orders.jsonltests/serve_backfill.rs:441version: 1\u{a}name: slow\u{a}pipeline:\u{a} source:\u{a} type: sqlite\u{a} config:\u{a} database_url: "sqlite://{src}"\u{a} query: "WITH RECURSIVE c(x) AS (SELECT 1 UNION ALL SELECT …tests/serve_backfill.rs:538http://127.0.0.1:{port}/healthztests/serve_callback.rs:85 tests/serve_callback.rs:463 tests/serve_catalog.rs:93 tests/serve_changes.rs:115 tests/serve_cluster.rs:207 tests/serve_dlq.rs:92 tests/serve_lifecycle.rs:84 tests/serve_lifecycle.rs:426 tests/serve_local_outputs.rs:121 tests/serve_logs.rs:84 tests/serve_metrics.rs:80 tests/serve_mirror_status.rs:85 tests/serve_policy_plan.rs:119 tests/serve_preview.rs:138 tests/serve_rbac.rs:109 tests/serve_sql_sandbox.rs:91 tests/serve_state_status.rs:95 tests/serve_tenants.rs:193 tests/serve_trust_boundaries.rs:138 tests/serve_usage.rs:88 tests/serve_verify_rollback.rs:100 tests/topology_runtimes.rs:547http://127.0.0.1:{port}/v1/runstests/serve_callback.rs:148 tests/serve_callback.rs:192 tests/serve_callback.rs:230 tests/serve_callback.rs:277 tests/serve_callback.rs:303 tests/serve_callback.rs:331 tests/serve_callback.rs:420 tests/serve_callback.rs:477 tests/serve_callback.rs:492 tests/serve_cluster.rs:512http://127.0.0.1:{port}/v1/runs/{run_id}tests/serve_callback.rs:247http://[fd00:ec2::254]/latest/api/tokentests/serve_callback.rs:299http://100.100.100.200/latest/meta-data/tests/serve_callback.rs:300http://127.0.0.1:{port}/v1/backfilltests/serve_callback.rs:360http://127.0.0.1:{port}tests/serve_catalog.rs:159 tests/serve_catalog.rs:333 tests/serve_changes.rs:207 tests/serve_changes.rs:717 tests/serve_changes.rs:903 tests/serve_changes.rs:943 tests/serve_cluster_secret_params.rs:98 tests/serve_dlq.rs:133 tests/serve_history_sqlite.rs:458 tests/serve_lifecycle.rs:128 tests/serve_lifecycle.rs:171 tests/serve_lifecycle.rs:234 tests/serve_lifecycle.rs:283 tests/serve_lifecycle.rs:369 tests/serve_lifecycle.rs:436 tests/serve_lifecycle.rs:540 tests/serve_local_outputs.rs:203 tests/serve_local_outputs.rs:343 tests/serve_local_outputs.rs:400 tests/serve_local_outputs.rs:529 tests/serve_local_outputs.rs:599 tests/serve_local_outputs.rs:646 tests/serve_local_outputs.rs:707 tests/serve_local_outputs.rs:777 tests/serve_local_outputs.rs:847 tests/serve_log_shipping.rs:649 tests/serve_logs.rs:112 tests/serve_metrics.rs:109 tests/serve_mirror_status.rs:124 tests/serve_openapi.rs:174 tests/serve_policy_plan.rs:200 tests/serve_policy_plan.rs:341 tests/serve_preview.rs:258 tests/serve_preview.rs:377 tests/serve_preview.rs:420 tests/serve_preview.rs:498 tests/serve_preview.rs:542 tests/serve_preview.rs:605 tests/serve_preview.rs:642 tests/serve_preview.rs:678 tests/serve_preview.rs:726 tests/serve_preview.rs:770 tests/serve_rbac.rs:137 tests/serve_rbac.rs:202 tests/serve_rbac.rs:456 tests/serve_run_depends_on.rs:127 tests/serve_shard_cancel.rs:87 tests/serve_shard_cancel.rs:190 tests/serve_shard_cancel.rs:278 tests/serve_sql_sandbox.rs:101 and 19 morekind: pipeline\u{a}version: 1\u{a}name: tpl-b\u{a}pipeline:\u{a} source: { type: rest, config: { base_url: "https://example.com", path: /rows } }\u{a} sink: { type: jsonl, config: { path: ./out-b.js…tests/serve_changes.rs:494http://127.0.0.1:{port_a}/v1/runstests/serve_cluster.rs:237http://127.0.0.1:{port_b}/v1/runs/{id}tests/serve_cluster.rs:271 tests/serve_cluster.rs:297http://127.0.0.1:{port}/readyztests/serve_cluster.rs:485http://127.0.0.1:{port}/v1/runs/{id}tests/serve_cluster.rs:531http://{}tests/serve_history_degraded.rs:246 tests/serve_history_degraded.rs:344 tests/serve_pools.rs:84postgres://postgres:postgres@127.0.0.1:{port}/postgrestests/serve_history_postgres.rs:33 tests/serve_run_labels.rs:438 tests/sql_incremental.rs:113 tests/verify_postgres.rs:21file://{path}tests/serve_history_sqlite.rs:1362file:///out.jsonltests/serve_history_sqlite.rs:1504csv://atests/serve_history_sqlite.rs:2018 tests/serve_history_sqlite.rs:2043 tests/serve_history_sqlite.rs:2071 tests/serve_history_sqlite.rs:2107 tests/serve_history_sqlite.rs:2153csv://btests/serve_history_sqlite.rs:2019 tests/serve_history_sqlite.rs:2044 tests/serve_history_sqlite.rs:2101 tests/serve_history_sqlite.rs:2163csv://ctests/serve_history_sqlite.rs:2026csv://dtests/serve_history_sqlite.rs:2027csv://sharedtests/serve_history_sqlite.rs:2098 tests/serve_history_sqlite.rs:2125csv://srctests/serve_history_sqlite.rs:2328csv://dsttests/serve_history_sqlite.rs:2329 tests/serve_history_sqlite.rs:2334https://app.exampletests/serve_http_hardening.rs:24 tests/serve_http_hardening.rs:89 tests/serve_http_hardening.rs:102https://logs.example/explore?run={run_id}&t={tenant}tests/serve_log_shipping.rs:588https://logs.example/explore?run=n-1&t=tests/serve_log_shipping.rs:621https://g/explore?q={run_id}tests/serve_log_shipping.rs:643https://g/explore?q={id}tests/serve_log_shipping.rs:700https://g/exploretests/serve_log_shipping.rs:748https://g/explore?q=aged-1tests/serve_log_shipping.rs:762http://127.0.0.1:{port}/v1/runs/does-not-exist/logstests/serve_logs.rs:195endpoint: http://{addr}\u{a}protocol: http\u{a}export: [traces, metrics]\u{a}service_name: faucet-serve-test\u{a}tests/serve_otel.rs:49http://127.0.0.1:{port}/mcptests/serve_rbac.rs:511https://x:8080tests/serve_run_labels.rs:54url:https://x:8080tests/serve_run_labels.rs:81version: 1\u{a}name: nightly\u{a}pipeline:\u{a} source: {type: rest, config: {base_url: "https://x", path: /e}}\u{a} sink: {type: stdout, config: {}}\u{a}tests:\u{a} suite:\u{a} auto: {defaults_…tests/serve_templates_sync.rs:18 tests/template_sync_cmd.rs:13version: 1\u{a}providers:\u{a} - name: crm\u{a} authorize_url: {idp}/authorize\u{a} token_url: {idp}/token\u{a} client_id: cid\u{a} client_secret: csecret\u{a} scopes: [read, offline_a…tests/serve_tenants.rs:162http://127.0.0.1:9/xtests/serve_tenants.rs:414http://10.0.0.5/xtests/serve_tenants.rs:415http://[::1]/xtests/serve_tenants.rs:416https://faucet.example/v1/connect/callbacktests/serve_tenants.rs:674https://app.example/done?connection=crm&status=oktests/serve_tenants.rs:690version: 1\u{a}name: linkfail\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: http://127.0.0.1:9\u{a} path: /x\u{a} sink:\u{a} type: jsonl\u{a} config:…tests/serve_tenants.rs:1373version: 1\u{a}name: cb\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} base_url: http://127.0.0.1:9\u{a} path: /x\u{a} sink:\u{a} type: jsonl\u{a} config:\u{a} …tests/serve_tenants.rs:1394# pipeline that uses the request body as a REST source filter\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config:\u{a} url: "https://api.example.com/orders?dataset=${trigger.query.data…tests/serve_triggers.rs:313https://api.example.com/orders?dataset=orderstests/serve_triggers.rs:338version: 1\u{a}triggers:\u{a} - name: drain\u{a} type: queue_depth\u{a} threshold: 5\u{a} queue: {{ type: redis, url: "redis://x", key: jobs }}\u{a} config: {}\u{a}tests/serve_triggers.rs:753 tests/serve_triggers.rs:942 tests/serve_triggers.rs:999version: 1\u{a}triggers:\u{a} - name: drop\u{a} type: object_arrival\u{a} store: {{ type: s3, bucket: b, region: us-east-1, endpoint: "http://127.0.0.1:9" }}\u{a} lookback_secs: 3600\u{a} …tests/serve_triggers.rs:1677http://169.254.169.254/latesttests/serve_triggers.rs:1811s3://b/out/part-{part}.jsonltests/shared_destination.rs:43x://h/dbtests/sql_incremental.rs:153version: 1\u{a}name: orders\u{a}pipeline:\u{a} source: {{ type: csv, config: {{ path: {input} }} }}\u{a} sink: {{ type: sqlite, config: {{ database_url: "sqlite://{db}?mode=rwc", table_name: t, colu…tests/state_cmd.rs:33version: 1\u{a}name: cdc\u{a}delivery: exactly_once\u{a}pipeline:\u{a} source: {{ type: postgres-cdc, config: {{ connection_url: "postgres://u:p@localhost/db", slot_name: s, publication: p }} }}\u{a}…tests/state_cmd.rs:441 tests/status_cmd.rs:217postgres://postgres:postgres@127.0.0.1:{}/postgrestests/state_cmd.rs:574redis://127.0.0.1:{}tests/state_cmd.rs:578version: 1\u{a}name: orders\u{a}pipeline:\u{a} sources:\u{a} csv: {{ type: csv, config: {{ path: {input} }} }}\u{a} cdc:\u{a} type: mongodb-cdc\u{a} config:\u{a} connection_uri…tests/state_versioning.rs:40version: 1\u{a}name: shop\u{a}pipeline:\u{a} source: {{ type: csv, config: {{ path: {input} }} }}\u{a} sink: {{ type: sqlite, config: {{ database_url: "sqlite://{db}?mode=rwc", table_name: t, column…tests/status_cmd.rs:53version: 1\u{a}name: ovw\u{a}pipeline:\u{a} source: {{ type: csv, config: {{ path: {input} }} }}\u{a} sink: {{ type: sqlite, config: {{ database_url: "sqlite://{db}?mode=rwc", table_name: t, column_…tests/status_cmd.rs:408 tests/status_cmd.rs:476sqlite://{}tests/status_cmd.rs:425 tests/status_cmd.rs:497http://{addr}tests/support/otlp_mock.rs:187 tests/support/otlp_mock.rs:411kind: pipeline\u{a}version: 1\u{a}name: {name}\u{a}params:\u{a} region:\u{a} type: string\u{a} default: us\u{a} values: [us, eu]\u{a}pipeline:\u{a} source:\u{a} type: rest\u{a} config…tests/template_test_gate.rs:25kind: source-template\u{a}name: acme\u{a}description: acme\u{a}source:\u{a} type: rest\u{a} config: { base_url: "https://example.com" }\u{a}streams:\u{a} - name: orders\u{a} source: { config: { …tests/template_test_gate.rs:253kind: source-template\u{a}name: acme\u{a}description: acme exports\u{a}source:\u{a} type: rest\u{a} config: { base_url: "https://example.com" }\u{a}streams:\u{a} - name: orders\u{a} source: { co…tests/template_test_gate.rs:331\u{a}version: 1\u{a}name: e2e\u{a}vars:\u{a} api_base: https://api.example.com\u{a}\u{a}pipeline:\u{a} sources:\u{a} users_api:\u{a} type: rest\u{a} config:\u{a} base_url: ${vars…tests/templates_end_to_end.rs:14https://api.example.com/audittests/templates_end_to_end.rs:70version: 1\u{a}name: offline_validate\u{a}pipeline:\u{a} sources:\u{a} o: {{ type: csv, config: {{ path: {csv} }} }}\u{a} sinks:\u{a} pg:\u{a} type: postgres\u{a} config:\u{a} …tests/topology_end_to_end.rs:246version: 1\u{a}name: eo\u{a}delivery: exactly_once\u{a}pipeline:\u{a} state: { type: memory, config: {} }\u{a} sources:\u{a} o: { type: postgres-cdc, config: { connection_url: "postgres://x/y", s…tests/topology_end_to_end.rs:1241version: 1\u{a}name: eo\u{a}delivery: exactly_once\u{a}pipeline:\u{a} state: { type: file, config: { path: ./st } }\u{a} sources:\u{a} a: { type: postgres-cdc, config: { connection_url: "postgres…tests/topology_end_to_end.rs:1268\u{a}version: 1\u{a}name: layering_e2e\u{a}pipeline:\u{a} transforms:\u{a} - {{ type: set, config: {{ values: {{ _layer: pipeline }} }} }}\u{a} sources:\u{a} s:\u{a} type: rest\u{a} …tests/transforms_layering.rs:14
info unsafe_code library 17
2 unsafe blocks, functions or implssrc/config.rs:1914 src/memstat.rs:37 src/pipeline_state/lease.rs:90 src/templates/store.rs:2420 src/templates/sync/mod.rs:11094 unsafe blocks, functions or implssrc/hub/mod.rs:1327 src/obs.rs:140 src/params/bind.rs:193711 unsafe blocks, functions or implssrc/hub/remote.rs:75419 unsafe blocks, functions or implssrc/interpolate.rs:11841 unsafe blocks, functions or implssrc/local_outputs/mod.rs:105 src/runtime/adapter_matrix.rs:1055 src/serve/load.rs:3285 src/serve/rbac.rs:8315 unsafe blocks, functions or implssrc/secrets/vault.rs:254 src/serve/config.rs:5593 unsafe blocks, functions or implssrc/serve/handlers/templates.rs:3010
info unsafe_code test 7
1 unsafe blocks, functions or implstests/env_mode.rs:16 tests/serve_error_redaction.rs:87 tests/serve_reference_policy.rs:207 tests/serve_templates_sync.rs:1462 unsafe blocks, functions or implstests/hub_remote_index.rs:62 tests/serve_changes.rs:892 tests/serve_trust_boundaries.rs:187
info environment_enumeration test 1
std::env::vars, keys onlytests/env_mode.rs:11
Run: check
failed- Ended
- agent reported the end
- Guest
- exit code 101
- Run time
- 1.2 s
- VM restore
- 93 ms
- Payload
- 62385 files, 1.1 GiB
- Files opened
- 2315
Processes 1
Siblings that ran the same program with the same result and the same processes below are folded into one row, with their number.
| Process | Arguments | Start | Took | Exit |
|---|---|---|---|---|
| cargo /usr/local/bin/cargo | check --locked --offline | 5 ms | 1.2 s | 25856 |
Network 0
No network activity.
Files 0
Secrets opened
None.
Written outside the build directories
None.
Scratch disk 0
- Files
- 7
- Directories
- 12
- Size
- 56.6 KiB
- Compiled units
- 0
Nothing outside the build areas.
Output
Standard error
error: rustc 1.98.1 is not supported by the following packages: faucet-auth@1.5.0 requires rustc 1.99 faucet-cli@1.16.0 requires rustc 1.99 faucet-cli@1.16.0 requires rustc 1.99 faucet-cli@1.16.0 requires rustc 1.99 faucet-common-azure@1.2.3 requires rustc 1.99 faucet-common-bigquery@1.3.0 requires rustc 1.99 faucet-common-databricks@1.1.2 requires rustc 1.99 faucet-common-delta@1.3.2 requires rustc 1.99 faucet-common-dynamodb@1.2.0 requires rustc 1.99 faucet-common-elasticsearch@1.2.0 requires rustc 1.99 faucet-common-file@1.1.2 requires rustc 1.99 faucet-common-gcs@1.3.0 requires rustc 1.99 faucet-common-iceberg@1.2.0 requires rustc 1.99 faucet-common-kafka@1.3.0 requires rustc 1.99 faucet-common-kinesis@1.2.0 requires rustc 1.99 faucet-common-mssql@1.3.0 requires rustc 1.99 faucet-common-nats@1.2.2 requires rustc 1.99 faucet-common-pubsub@1.3.0 requires rustc 1.99 faucet-common-rabbitmq@1.1.2 requires rustc 1.99 faucet-common-redis@1.0.0 requires rustc 1.99 faucet-common-redshift@1.2.2 requires rustc 1.99 faucet-common-s3@1.0.1 requires rustc 1.99 faucet-common-sftp@1.1.2 requires rustc 1.99 faucet-common-singer@1.1.1 requires rustc 1.99 faucet-common-snowflake@1.3.0 requires rustc 1.99 faucet-common-spanner@1.2.2 requires rustc 1.99 faucet-common-sql@1.1.0 requires rustc 1.99 faucet-common-sqs@1.2.0 requires rustc 1.99 faucet-core@1.15.0 requires rustc 1.99 faucet-lineage@2.4.0 requires rustc 1.99 faucet-registry@1.0.0 requires rustc 1.99 faucet-sink-azure-blob@1.2.3 requires rustc 1.99 faucet-sink-bigquery@1.10.0 requires rustc 1.99 faucet-sink-clickhouse@1.4.0 requires rustc 1.99 faucet-sink-csv@1.6.0 requires rustc 1.99 faucet-sink-databricks@1.2.0 requires rustc 1.99 faucet-sink-delta@1.4.1 requires rustc 1.99 faucet-sink-duckdb@1.3.0 requires rustc 1.99 faucet-sink-dynamodb@1.2.0 requires rustc 1.99 faucet-sink-elasticsearch@1.8.0 requires rustc 1.99 faucet-sink-file@1.1.2 requires rustc 1.99 faucet-sink-gcs@1.6.0 requires rustc 1.99 faucet-sink-http@1.6.0 requires rustc 1.99 faucet-sink-iceberg@1.7.0 requires rustc 1.99 faucet-sink-jsonl@1.6.0 requires rustc 1.99 faucet-sink-kafka@1.7.0 requires rustc 1.99 faucet-sink-kinesis@1.3.0 requires rustc 1.99 faucet-sink-mongodb@1.9.0 requires rustc 1.99 faucet-sink-mssql@1.8.0 requires rustc 1.99 faucet-sink-mysql@1.10.0 requires rustc 1.99 faucet-sink-nats@1.2.1 requires rustc 1.99 faucet-sink-parquet@1.6.0 requires rustc 1.99 faucet-sink-postgres@1.10.0 requires rustc 1.99 faucet-sink-pubsub@1.3.0 requires rustc 1.99 faucet-sink-rabbitmq@1.1.1 requires rustc 1.99 faucet-sink-redis@1.6.0 requires rustc 1.99 faucet-sink-redshift@1.4.0 requires rustc 1.99 faucet-sink-s3@1.7.0 requires rustc 1.99 faucet-sink-sftp@1.2.2 requires rustc 1.99 faucet-sink-singer@1.1.1 requires rustc 1.99 faucet-sink-snowflake@1.8.0 requires rustc 1.99 faucet-sink-spanner@1.4.0 requires rustc 1.99 faucet-sink-sqlite@1.10.0 requires rustc 1.99 faucet-sink-sqs@1.3.0 requires rustc 1.99 faucet-sink-stdout@1.6.0 requires rustc 1.99 faucet-source-azure-blob@1.2.3 requires rustc 1.99 faucet-source-bigquery@1.7.0 requires rustc 1.99 faucet-source-clickhouse@1.2.2 requires rustc 1.99 faucet-source-csv@1.7.0 requires rustc 1.99 faucet-source-databricks@1.3.2 requires rustc 1.99 faucet-source-delta@1.4.2 requires rustc 1.99 faucet-source-duckdb@1.4.0 requires rustc 1.99 faucet-source-dynamodb@1.2.0 requires rustc 1.99 faucet-source-elasticsearch@1.7.0 requires rustc 1.99 faucet-source-file@1.1.2 requires rustc 1.99 faucet-source-gcs@1.9.0 requires rustc 1.99 faucet-source-graphql@1.8.0 requires rustc 1.99 faucet-source-grpc@1.6.0 requires rustc 1.99 faucet-source-grpc@1.6.0 requires rustc 1.99 faucet-source-grpc@1.6.0 requires rustc 1.99 faucet-source-iceberg@1.2.0 requires rustc 1.99 faucet-source-kafka@1.6.0 requires rustc 1.99 faucet-source-kinesis@1.3.0 requires rustc 1.99 faucet-source-mongodb@1.8.0 requires rustc 1.99 faucet-source-mongodb-cdc@1.5.0 requires rustc 1.99 faucet-source-mssql@1.7.0 requires rustc 1.99 faucet-source-mssql-cdc@1.2.2 requires rustc 1.99 faucet-source-mysql@1.9.0 requires rustc 1.99 faucet-source-mysql-cdc@1.5.0 requires rustc 1.99 faucet-source-nats@1.2.1 requires rustc 1.99 faucet-source-parquet@1.7.0 requires rustc 1.99 faucet-source-postgres@1.10.0 requires rustc 1.99 faucet-source-postgres-cdc@1.6.0 requires rustc 1.99 faucet-source-pubsub@1.3.0 requires rustc 1.99 faucet-source-rabbitmq@1.1.1 requires rustc 1.99 faucet-source-redis@1.6.0 requires rustc 1.99 faucet-source-redshift@1.3.0 requires rustc 1.99 faucet-source-rest@1.9.0 requires rustc 1.99 faucet-source-s3@1.11.0 requires rustc 1.99 faucet-source-sftp@1.3.2 requires rustc 1.99 faucet-source-singer@1.3.1 requires rustc 1.99 faucet-source-snowflake@1.6.0 requires rustc 1.99 faucet-source-spanner@1.3.2 requires rustc 1.99 faucet-source-sqlite@1.9.0 requires rustc 1.99 faucet-source-sqs@1.3.0 requires rustc 1.99 faucet-source-webhook@1.4.0 requires rustc 1.99 faucet-source-websocket@1.4.0 requires rustc 1.99 faucet-source-xml@1.9.0 requires rustc 1.99 faucet-state-postgres@1.5.0 requires rustc 1.99 faucet-state-redis@1.3.0 requires rustc 1.99 Either upgrade rustc or select compatible dependency versions with `cargo update <name>@<current-ver> --precise <compatible-ver>` where `<compatible-ver>` is the latest version supporting rustc 1.98.1
Timeline
6
| When | From | To | Event | Worker |
|---|---|---|---|---|
| 2026-10-29 21:28 UTC | Discovered | Fetched | fetched | fetcher-12688 |
| 2026-10-29 21:28 UTC | Fetched | ReadyForSandbox | static_analysis_completed | static-12726 |
| 2026-10-29 21:28 UTC | ReadyForSandbox | Running | sandbox_started | orchestrator-12760-slot1 |
| 2026-10-29 21:28 UTC | Running | DynamicallyAnalyzed | sandbox_completed | orchestrator-12760-slot1 |
| 2026-10-29 21:28 UTC | DynamicallyAnalyzed | Scored | scored | analyzer-12816 |
| 2026-10-29 21:28 UTC | Scored | Done | finalized | analyzer-12816 |