Commit Graph

53 Commits

Author SHA1 Message Date
vitor-aignosi
4a672745c5 SIENTIAPDE-1445
Add debug print statement in gather_read_tags function to log workflow type and read tags for better traceability.
2025-12-18 11:29:33 -03:00
vitor-aignosi
38684071a5 SIENTIAPDE-1445
Filter gather_read_tags to process only 'scouter' workflow types and add corresponding unit tests to validate this behavior.
2025-12-18 11:21:55 -03:00
vitor-aignosi
c98469efd2 SIENTIAPDE-1445
Update GITHUB_BRANCH to feature/SIENTIAPDE-1445 and enhance formatters with a new registry for workflow types, improving configuration management. Refactor process_schedules to utilize the new registry and add error handling for unsupported workflow types. Update tests to validate new functionality and ensure proper integration.
2025-12-18 10:55:29 -03:00
vitor-aignosi
61d4b23e69 SIENTIAPDE-1445
SIENTIAPDE-1273 Add base_scouter and pi_web_api_scouter functions to orchestrator utilities for enhanced configuration management. Update tests to validate new functionalities and ensure proper integration with existing workflows.
2025-12-18 10:02:47 -03:00
vitor-aignosi
62e7a7dee9 SIENTIAPDE-1273
SIENTIAPDE-1273 Add 'save_transform' and 'transform_table_name' parameters to predictions_batch function for enhanced data processing capabilities. Update corresponding test cases to reflect these changes.
2025-11-19 08:12:08 -03:00
vitor-aignosi
fdd859de5a SIENTIAPDE-1273
Enhance orchestrator utilities and activities with improved documentation and functionality. Update README to reflect new orchestrator functions for drift and simple metrics workflows. Refactor email, formatters, mongo_db, slot_manager, and temporal_manager activities to include detailed docstrings and improve clarity on input parameters and return values. Ensure consistent metadata handling across activities for better logging and tracking.
2025-11-17 16:30:29 -03:00
vitor-aignosi
2f06036d0e SIENTIAPDE-1273
SIENTIAPDE-1273 Refactor drift function in orchestrator utilities for improved configuration and update formatters to include drift import. Enhance tests to validate new configurations and ensure integration with existing workflows.
2025-11-17 12:57:17 -03:00
vitor-aignosi
7d0c23acb6 SIENTIAPDE-1273
Update sientia-dataops-library dependency to version 1.6.1 and add target_table_name to simple_metrics configuration for enhanced metrics tracking.
2025-11-17 10:47:40 -03:00
vitor-aignosi
7b28424a34 SIENTIAPDE-1273
Implement simple metrics configuration in formatters and orchestrator utilities. Update tests to validate new simple metrics functionality and ensure proper integration with existing workflows.
2025-11-14 15:55:06 -03:00
vitor-aignosi
c9b5e98726 SIENTIAPDE-1273
Implement drift monitoring configuration and update formatters to support drift workflows. Add drift function to orchestrator utilities and enhance tests for drift functionality.
2025-11-14 09:22:24 -03:00
vitor-aignosi
6882d085e6 SIENTIAPDE-1312
SIENTIAPDE-1312: Refactor build_tag_config to accept a list of tags and return notifications for missing servers. Update Formatters to handle notifications during slot configuration. Enhance tests to validate new behavior and error reporting.
2025-10-21 08:58:39 -03:00
vitor-aignosi
61fea4bb75 SIENTIAPDE-1312
SIENTIAPDE-1312: Add 'fill_missing_tags' configuration option to scouter function for enhanced tag management.
2025-10-20 16:26:39 -03:00
vitor-aignosi
e04c91f6f8 SIENTIAPDE-1312
SIENTIAPDE-1312: Update build_tag_config to ensure minimum frequency defaults to 1000 and convert frequency values to integers for accurate calculations of subscription_period_ms.
2025-10-20 12:47:02 -03:00
vitor-aignosi
1666702d73 SIENTIAPDE-1312
SIENTIAPDE-1312: Update build_tag_config to calculate subscription_period_ms based on minimum frequency from tags. Enhance test_build_tag_config to include frequency and validate subscription_period_ms.
2025-10-20 12:42:20 -03:00
vitor-aignosi
b095335cdc SIENTIAPDE-1312
Update sientia-dataops-library dependency to version 1.4.7 and enhance TemporalManager to support offset configuration for scheduling. Added offset handling in common configuration and updated related tests to validate new functionality.
2025-10-20 10:26:53 -03:00
vitor-aignosi
9031b4c88f SIENTIAPDE-1231
Enhance README and code documentation for clarity and structure

- Added a comprehensive Table of Contents to the README for easier navigation.
- Introduced a new section on Code Quality & Validation, detailing the validation workflow and tools used.
- Improved descriptions and consistency in docstrings across various modules, including metrics, formatters, and MongoDB activities.
- Clarified function return types and arguments in the MongoDB and TemporalManager classes for better understanding.
2025-10-16 10:33:58 -03:00
vitor-aignosi
6b826863f4 SIENTIAPDE-1231
Enhance type hinting and code structure in orchestrator activities

- Added type hints for better code clarity in `formatters.py`, `mongo_db.py`, `temporal_manager.py`, and `email_builder.py`.
- Updated `.gitignore` to include `coverage.xml` for improved coverage reporting.
- Improved readability by restructuring variable declarations and method signatures.
2025-10-16 08:52:38 -03:00
vitor-aignosi
f3a6af5603 SIENTIAPDE-1231
Refactor orchestrator activities and configuration files

- Removed unused Temporal timeout environment variables from values.yaml.
- Reorganized import statements in various activity files for better readability.
- Updated logging messages to use consistent formatting across activities.
- Enhanced test cases to ensure proper initialization and shutdown of orchestrator activities.
- Improved overall code structure and readability by applying consistent formatting and style adjustments.
2025-10-15 17:20:52 -03:00
vitor-aignosi
310cae4c2f SIENTIAPDE-1231
SIENTIAPDE-1231: Add timeout configuration for Temporal tasks

- Introduced new timeout parameters in values.yaml for task execution.
- Updated TemporalManager to utilize execution and task timeout settings in seconds.
- Enhanced orchestrator_functions.py to include default timeout values for better orchestration control.
2025-10-10 15:55:03 -03:00
vitor-aignosi
5fdabd27c0 SIENTIAPDE-1231
Update orchestration configuration and execution parameters

- Adjusted execution counts in Jupyter notebook cells for better tracking.
- Updated schedule name in the orchestration configuration to align with new requirements.
- Modified `values.yaml` to change the GitHub branch for improved versioning.
- Enhanced `Activities` and `TemporalManager` classes to include timeout parameters for task execution.
- Updated connector configuration to include new timeout settings for better orchestration control.
2025-10-06 13:46:17 -03:00
vitor-aignosi
49f3429556 SIENTIAPDE-1222
SIENTIAPDE-1222 Refactor server configuration handling in orchestrator_functions.py and update related tests

- Removed the security_spec field from server configuration in build_tag_config to streamline the configuration process.
- Updated test cases in test_formatters.py and test_orchestrator_functions.py to reflect the removal of security_spec, ensuring alignment with the new configuration structure and improving test accuracy.
2025-09-24 10:57:38 -03:00
vitor-aignosi
02b647931f SIENTIAPDE-1222
Enhance OPC server configuration in orchestrator_functions.py

- Added optional fields for certificate paths in the build_tag_config function to improve security configuration flexibility.
2025-09-19 08:56:40 -03:00
vitor-aignosi
137367c963 SIENTIAPDE-1222
Refactor orchestration and email handling

- Updated the orchestration queries to streamline model lookups and added conditions for active models.
- Changed the entry point in the local run script to use the worker module.
- Removed the deprecated samples.json file.
- Enhanced the Email activity to skip sending if the SMTP server is not configured.
- Added timestamp field handling in MongoDB activities for better data management.
- Updated connectors configuration to allow for a None SMTP server.
- Improved the common configuration function to include model configuration details.
2025-09-12 14:39:42 -03:00
vitor-aignosi
42565b5983 SIENTIAPDE-1182
Update environment variables in values.yaml and enhance predictions_batch function in orchestrator_functions.py

- Changed GITHUB_BRANCH to reflect the new task for adjusting laborious processes to capture timestamps from MLflow.
- Added a new filter configuration for handling empty data in the predictions_batch function to improve error management.
2025-09-04 15:39:27 -03:00
vitor-aignosi
01b4c7a126 SIENTIAPDE-1182
Remove deprecated files and configurations

- Deleted coverage.sh, Dockerfile, docker-compose.yml, email.html, input_sample.json, and Makefile as part of the cleanup process.
- Updated README.md to reflect the removal of these components and provide a clearer overview of the project structure and functionality.
- Added module-level docstrings to orchestrator, activities, and workflows for improved documentation and clarity on system architecture.
2025-09-01 15:49:44 -03:00
vitor-aignosi
36f1388301 SIENTIAPDE-1182
SIENTIAPDE-1205: Enhance predictions_batch function and update test cases

- Added 'predictions_storage_policy' to the predictions_batch function for improved configuration handling.
- Updated test cases to include 'predictions_storage_policy' in expected results, ensuring consistency in testing.
2025-09-01 15:49:44 -03:00
vitor-aignosi
575a99fd31 SIENTIAPDE-1193
chore: update image tag and enhance datetime column handling in orchestrator functions

- Updated the image tag in values.yaml from 0.4.2 to 0.4.4 for the latest version.
- Added support for datetime_columns in minimal_retrain and predictions_batch functions to improve timestamp handling in orchestrator functions.
2025-08-25 10:04:26 -03:00
vitor-aignosi
d7effd44e5 SIENTIAPDE-1193
refactor: update date handling and remove deprecated constants

- Replaced the usage of datetime.now() with a new now() function from sientia_do.temporal.constants for consistent timestamp handling across multiple files.
- Updated the date format from DEFAULT_DATE_FORMAT to DATETIME_FORMAT_MS_WITH_TZ in various activities to ensure uniformity in timestamp formatting.
- Removed the obsolete patterns.py file that contained the DEFAULT_DATE_FORMAT constant.
2025-08-25 10:04:26 -03:00
vitor-aignosi
9e49dd4255 SIENTIAPDE-1169
chore: update dependencies and refactor logger imports

- Updated the sientia-dataops-library dependency version from 1.3.8 to 1.4.1 in requirements.txt.
- Changed image tag in values.yaml from 0.4.0 to 0.4.2.
- Refactored logger imports in multiple files to use the new observability module instead of the temporal module.
- Updated retry policy imports in various workflow files to reflect the new structure.
2025-08-19 16:47:25 -03:00
vitor-aignosi
31f2ff2439 SIENTIAPDE-1184
refactor: enhance shutdown procedures and documentation across activities

- Added shutdown methods to MongoDB and Email classes to ensure proper resource cleanup.
- Updated docstrings for shutdown methods to clarify their purpose and functionality.
- Enhanced documentation for various methods across multiple classes, improving clarity on parameters and return values.
- Improved the main function and other utility functions with detailed docstrings for better understanding and maintainability.
2025-08-14 09:48:19 -03:00
vitor-aignosi
bc456cc8be SIENTIAPDE-1172
refactor: streamline email generation and enhance notification handling

- Updated email HTML structure to improve clarity and presentation of notifications.
- Enhanced notification generator to better manage execution counts and output formatting.
- Refactored Email class to improve error handling and logging during email sending.
- Adjusted EmailBuilder to efficiently process error, warning, and info models.
- Improved test coverage for email and notification functionalities to ensure reliability.
2025-07-29 10:25:31 -03:00
vitor-aignosi
c3ba2e4b5a SIENTIAPDE-1172
refactor: update email HTML structure and enhance notification generator

- Modified email HTML to reflect updated model names and error/warning messages.
- Adjusted notification generator to improve execution counts and streamline output handling.
- Refactored activities in orchestrator to correct parameter names and improve type hints for better clarity.
- Enhanced email builder to handle error, warning, and info models more efficiently.
2025-07-28 17:26:28 -03:00
vitor-aignosi
9bc238388a SIENTIAPDE-1172
feat: integrate email configuration and enhance orchestrator activities

- Added email configuration parameters to values.yaml for sender details and SMTP settings.
- Refactored Email class to correct parameter names and improve logging during initialization.
- Introduced build_email_config function to streamline email configuration retrieval.
- Updated worker.py to include email and Postgres configurations in the main orchestration process.
2025-07-28 16:12:22 -03:00
vitor-aignosi
f2cb0f057d SIENTIAPDE-1172
refactor: simplify EmailBuilder parameters and remove unused templates

- Removed unused template file attributes from EmailBuilder class.
- Updated parameters method to eliminate report_data argument, streamlining the function for better clarity and efficiency.
2025-07-25 16:51:56 -03:00
vitor-aignosi
2a5534cf64 SIENTIAPDE-1172
feat: enhance orchestrator activities with new email and Postgres integrations

- Added Email and Postgres classes to the Activities class for improved functionality.
- Introduced new methods in MongoDB and SlotManager for loading and managing data.
- Updated requirements.txt to include jinja2.
- Added new formatting activity for log reports in Formatters class.
- Enhanced test coverage for MongoDB and SlotManager activities.
2025-07-25 16:03:39 -03:00
vitor-aignosi
c1e6807ac3 SIENTIAPDE-1171
fix: update workflow_type in minimal_retrain function for consistency

- Changed workflow_type from "retrain" to "minimal_retrain" in the minimal_retrain function to align with the new schedule configuration.
2025-07-23 13:01:37 -03:00
vitor-aignosi
5a4d6c5706 SIENTIAPDE-1171
feat: add minimal_retrain function to orchestrator_functions.py for retraining workflows

- Introduced minimal_retrain function to streamline retraining configuration.
- The function integrates common configuration with specific parameters for retraining workflows.
2025-07-23 12:26:36 -03:00
vitor-aignosi
4905e61214 SIENTIAPDE-1166
feat: add TTL index functionality to MongoDB activities and update requirements

- Updated MongoDB class to accept TTL index duration in seconds.
- Implemented create_collection_with_ttl_index method to create collections with TTL indexes.
- Added environment variable for TTL index duration in connectors_config.
- Updated tests to cover new TTL index functionality and ensure proper behavior.
- Bumped sientia-dataops-library version to 1.3.4 in requirements.txt.
2025-07-22 15:09:15 -03:00
vitor-aignosi
92fbb704f5 SIENTIAPDE-1151
refactor: enhance error handling in build_tag_config and slot processing to include notifications for missing servers
2025-07-18 09:45:42 -03:00
vitor-aignosi
b3069c8a58 SIENTIAPDE-1150
chore: update image tag to 0.2.4 in values.yaml; refactor logging in slot_manager and temporal_manager for improved readability; modify MongoDB and Redis configurations for better defaults; enhance worker.py with new activities and error handling
2025-07-14 13:42:10 -03:00
vitor-aignosi
43206b578d SIENTIAPDE-1150
fix: implement schedule normalization and timestamp management in MongoDB activities, enhance orchestration workflow with new formatting and normalization methods
2025-07-14 13:00:46 -03:00
vitor-aignosi
31a1d5bf4e SIENTIAPDE-1148
refactor: update Temporal configuration keys in activities.py and temporal_manager.py for consistency and clarity
2025-07-11 10:44:26 -03:00
vitor-aignosi
7f9efa579a SIENTIAPDE-1148
refactor: update temporal configuration and refactor Activities class to support multiple namespaces for improved orchestration
2025-07-11 10:34:40 -03:00
vitor-aignosi
a848f20c6b SIENTIAPDE-1110
fix: handle missing input filters in predictions_batch function
2025-07-07 15:56:33 -03:00
vitor-aignosi
f7f95d3148 SIENTIAPDE-1110
Update GITHUB_BRANCH and helm version in values.yaml for SIENTIAPDE-1110
2025-07-07 15:50:19 -03:00
vitor-aignosi
0aa58ba1da SIENTIAPDE-1110
SIENTIAPDE-1110 add debug_data_package configuration option to scouter function
2025-07-07 11:03:48 -03:00
vitor-aignosi
7984cb29f4 SIENTIAPDE-1107
fix: remove unused imports from connectors_config.py
2025-06-16 12:39:37 -03:00
vitor-aignosi
a4e4d3b085 SIENTIAPDE-1107
feat: add MongoDB integration and update configuration for activities
2025-06-16 12:05:56 -03:00
vitor-aignosi
89ac81e5e5 SIENTIAPDE-1095
Fix read_tags access in gather_read_tags function and update samples.json to use write_tags
2025-06-10 08:32:16 -03:00
vitor-aignosi
caa7b125f9 SIENTIAPDE-1095
Refactor predictions_batch to use server_id instead of server_name; update values.yaml to set GITHUB_BRANCH to main; add new laborious pipeline configuration in samples.json
2025-06-10 08:25:50 -03:00