admin/stonks-oracle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

phase 17: fix text[]/varchar[] type mismatch in coverage-gaps SQL

Browse Source
This commit is contained in:
Celes Renata
2026-04-12 04:15:00 -07:00
parent d16e15c885
commit 4f2f113cda
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.kiro/specs/stonks-oracle/tasks.md
+4 -4
View File
@@ -174,7 +174,7 @@
## Phase 17 - First Vertical Slice: Live Pipeline End-to-End ## Phase 17 - First Vertical Slice: Live Pipeline End-to-End
- [-] 17. Activate the full data pipeline for a set of tracked symbols - [x] 17. Activate the full data pipeline for a set of tracked symbols
- [x] 17.1 Seed initial symbols and configure sources via the dashboard - [x] 17.1 Seed initial symbols and configure sources via the dashboard
- Use the dashboard Companies page to add 5-10 symbols (e.g. AAPL, MSFT, GOOGL, AMZN, TSLA, NVDA, META, JPM, V, UNH) - Use the dashboard Companies page to add 5-10 symbols (e.g. AAPL, MSFT, GOOGL, AMZN, TSLA, NVDA, META, JPM, V, UNH)
- For each company, add sources via the Company Detail → Sources tab: one `market_api` source (Polygon), one `news_api` source, one `filings_api` source - For each company, add sources via the Company Detail → Sources tab: one `market_api` source (Polygon), one `news_api` source, one `filings_api` source
@@ -216,7 +216,7 @@
- Check the dashboard Trends page shows trend cards with real data - Check the dashboard Trends page shows trend cards with real data
- _Requirements: 7.1, 7.2, 7.3_ - _Requirements: 7.1, 7.2, 7.3_
- [-] 17.6 Validate recommendation engine produces paper-trade recommendations - [x] 17.6 Validate recommendation engine produces paper-trade recommendations
- Check recommendation worker logs for recommendation generation - Check recommendation worker logs for recommendation generation
- Verify `recommendations` table has entries with action, confidence, thesis - Verify `recommendations` table has entries with action, confidence, thesis
- Verify `recommendation_evidence` links recommendations to documents - Verify `recommendation_evidence` links recommendations to documents
@@ -224,14 +224,14 @@
- Check the dashboard Recommendations page shows real recommendations - Check the dashboard Recommendations page shows real recommendations
- _Requirements: 8.1, 8.2, 8.3_ - _Requirements: 8.1, 8.2, 8.3_
- [ ] 17.7 Validate lake publisher writes analytical facts to MinIO/Trino - [x] 17.7 Validate lake publisher writes analytical facts to MinIO/Trino
- Check lake-publisher worker logs for Parquet writes - Check lake-publisher worker logs for Parquet writes
- Verify MinIO `stonks-lakehouse` bucket has partitioned Parquet files - Verify MinIO `stonks-lakehouse` bucket has partitioned Parquet files
- Verify Trino can query the lakehouse tables via the SQL Explorer page - Verify Trino can query the lakehouse tables via the SQL Explorer page
- Test a sample query: `SELECT * FROM lakehouse.stonks.documents LIMIT 10` - Test a sample query: `SELECT * FROM lakehouse.stonks.documents LIMIT 10`
- _Requirements: 10.1, 10.2, 10.3_ - _Requirements: 10.1, 10.2, 10.3_
- [ ] 17.8 Validate dashboard shows live data across all pages - [x] 17.8 Validate dashboard shows live data across all pages
- Verify Home page shows non-zero metrics (active companies, documents, recommendations) - Verify Home page shows non-zero metrics (active companies, documents, recommendations)
- Verify Companies page lists seeded companies with source counts - Verify Companies page lists seeded companies with source counts
- Verify Documents page shows ingested documents with parse quality badges - Verify Documents page shows ingested documents with parse quality badges
services/api/app.py
+2 -2
View File
@@ -1479,8 +1479,8 @@ async def get_source_coverage_gaps():
LEFT JOIN sources s ON s.company_id = c.id AND s.active = TRUE LEFT JOIN sources s ON s.company_id = c.id AND s.active = TRUE
WHERE c.active = TRUE WHERE c.active = TRUE
GROUP BY c.id, c.ticker, c.legal_name, c.sector GROUP BY c.id, c.ticker, c.legal_name, c.sector
HAVING NOT ARRAY['market_api', 'news_api', 'filings_api'] <@ ARRAY_AGG(DISTINCT s.source_type) FILTER (WHERE s.active) HAVING NOT ARRAY['market_api', 'news_api', 'filings_api']::text[] <@ ARRAY_AGG(DISTINCT s.source_type::text) FILTER (WHERE s.active)
OR ARRAY_AGG(DISTINCT s.source_type) FILTER (WHERE s.active) IS NULL OR ARRAY_AGG(DISTINCT s.source_type::text) FILTER (WHERE s.active) IS NULL
ORDER BY c.ticker""", ORDER BY c.ticker""",
) )