Commit Graph

15 Commits

Author SHA1 Message Date
vitor-aignosi
d27dde99a9 SIENTIAPDE-1100
Fix error handling in aggregate_data method by raising the caught exception
2025-06-12 09:27:37 -03:00
vitor-aignosi
8cf3273714 SIENTIAPDE-1082
Implement shutdown methods for Activities and Kafka; enhance error handling in worker main function
2025-06-09 15:09:53 -03:00
vitor-aignosi
7dbb9a29ea SIENTIAPDE-1094
Update environment configuration and refactor activity imports

- Changed Kafka, Redis, and Temporal host configurations to use localhost.
- Updated the version reference for the sientia-dataops-library in requirements.txt.
- Refactored import paths for activities to align with new module structure.
- Removed unused base.py and postgres.py files.
- Updated logger and policies imports to reflect new module locations.
- Adjusted values.yaml for branch and log level settings.
2025-06-09 09:43:06 -03:00
vitor-aignosi
7822a41040 Adjusting actions 2025-05-19 16:51:22 -03:00
vitor-aignosi
1839240495 core scouter fix 2025-05-19 16:29:45 -03:00
vitor-aignosi
b29d7ba65d SIENTIAPDE-1005
Adjusting super prepare activity call
2025-05-19 14:56:57 -03:00
vitor-aignosi
bb07de573f SIENTIAPDE-1005
Activities fix
2025-05-19 11:59:41 -03:00
vitor-aignosi
3050b66737 SIENTIAPDE-1005
Prepare activity fix
2025-05-19 11:51:49 -03:00
vitor-aignosi
b01b7c6e42 SIENTIAPDE-1005
Fix
2025-05-19 11:48:38 -03:00
vitor-aignosi
9b715ea8c9 SIENTIAPDE-1005
Redis auth
2025-05-19 10:08:45 -03:00
vitor-aignosi
df8a0fc706 SIENTIAPDE-1005
Enhance README and configuration files; add Redis authentication and update workflows
2025-05-16 16:30:43 -03:00
vitor-aignosi
e252ca7962 SIENTIAPDE-1005
Full coverage

Refactor code structure and improve logging configuration; update tests for activities and connectors
2025-05-16 12:58:36 -03:00
vitor-aignosi
b203b7d22c SIENTIAPDE-1005
Implement workflows for fake data generation, scouter processing, and core scouter operations

- Added `FakeData` workflow to generate random data and send it to a Kafka topic.
- Implemented `Scouter` workflow to load data from Kafka and trigger the core scouter workflow.
- Created `CoreScouter` workflow to process data through quality gates, aggregation, and export to PostgreSQL.
- Developed comprehensive unit tests for activities and workflows, ensuring proper functionality and error handling.
- Enhanced Redis and Postgres activities with robust testing for data handling and error notifications.
- Introduced quality filters for data validation and implemented tests to verify their functionality.
2025-05-15 16:53:24 -03:00
vitor-aignosi
4e579dd5bd SIENTIAPDE-1005
Add initial implementation of data processing activities and filters
2025-05-13 16:58:03 -03:00
vitor-aignosi
02bb052605 File structure 2025-05-13 12:09:26 -03:00