Commit Graph

11 Commits

Author SHA1 Message Date
vitor-aignosi
9329ae206c SIENTIAPDE-1163
Update sientia-dataops-library dependency version from 1.3.0 to 1.3.3 in requirements.txt and change GITHUB_BRANCH in values.yaml to SIENTIAPDE-1163-alterar-dinamica-de-notificacoes-para-usar-o-mongodb-ao-inves-do-kafka for improved notification handling.
2025-07-17 11:00:52 -03:00
vitor-aignosi
03f5518cd1 SIENTIAPDE-1163
Update sientia-dataops-library dependency version from 1.2.1 to 1.3.0 in requirements.txt
2025-07-16 09:23:02 -03:00
vitor-aignosi
a8fe8caf1e SIENTIAPDE-1110
Update sientia-dataops-library dependency version from 1.2.0 to 1.2.1 in requirements.txt for improved functionality.
2025-07-07 16:20:35 -03:00
vitor-aignosi
332612ac84 SIENTIAPDE-1110
Integrate Druid activity into the Activities class, adding support for Druid configuration and initialization. Update worker and connectors configuration to accommodate Druid, enhancing data processing capabilities.
2025-07-02 09:02:59 -03:00
vitor-aignosi
53337de74a SIENTIAPDE-1110
SIENTIAPDE-1110 Add MongoDB integration and enhance Redis activity with timestamp management functions.
2025-07-01 15:10:32 -03:00
vitor-aignosi
704099c387 SIENTIAPDE-1110
Update Kafka activity to use AIOKafkaConsumer for asynchronous message handling, enhancing consumer management and adding support for multiple topics.
2025-07-01 10:44:37 -03:00
vitor-aignosi
4a90b77786 SIENTIAPDE-1110
Update sientia-dataops-library version to 1.2.0 in requirements.txt; refactor logging in activities to use a unified Logger instance and include metadata in log messages across various activities.
2025-06-26 15:15:31 -03:00
vitor-aignosi
f541e05e29 Update sientia-mlops-library version to 0.38.1 in requirements.txt 2025-06-09 15:12:43 -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
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