Commit Graph

222 Commits

Author SHA1 Message Date
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
10f54d1c3b SIENTIAPDE-1312
Update GITHUB_BRANCH in values.yaml to reflect improvements and fixes in data pipelines for SIENTIAPDE-1312.
2025-10-20 10:36:48 -03:00
vitor-aignosi
65dc76209b SIENTIAPDE-1312
Enhance type hinting in test_orchestrator_functions.py by specifying the type of slot_config as a dictionary for improved code clarity.
2025-10-20 10:27:47 -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
Matheus Demoner
b693329f76 Merge pull request #25 from Aignosi/SIENTIAPDE-1318-adicionar-pipeline-de-qualidade
SIENTIAPDE-1318: Enhance Code Quality Checks
2025-10-20 08:37:07 -03:00
vitor-aignosi
be1b0cb41c SIENTIAPDE-1318
Update GitHub Actions workflow to target 'orchestrator/' directory for code quality checks

- Modified paths in the quality-gate.yml file to replace 'laborious/' with 'orchestrator/' for code formatting, linting, type checking, and security analysis steps.
2025-10-17 13:00:13 -03:00
vitor-aignosi
aaff7320b8 SIENTIAPDE-1318
Update sientia-dataops-library dependency version in requirements.txt to 1.4.6
2025-10-17 12:56:10 -03:00
vitor-aignosi
99fb460ddb SIENTIAPDE-1318
Enhance validation script and CI workflow for code quality checks

- Added support for a --fix option in validate.sh to apply Ruff auto-fixes for formatting and linting.
- Updated GitHub Actions workflow to include separate steps for installing development and runtime dependencies.
- Introduced dedicated steps for code formatting and linting checks using Ruff, along with type checking and security analysis using mypy and Bandit.
2025-10-17 12:50:02 -03:00
Matheus Demoner
a834671be4 Merge pull request #24 from Aignosi/SIENTIAPDE-1231-ajustar-o-retreino-do-courier-no-laborious
SIENTIAPDE-1231: Refactor Orchestrator Activities and Add Timeout Configuration
2025-10-16 12:22:18 -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
c9f83186c8 SIENTIAPDE-1231
Remove coverage.xml file to streamline project structure and improve version control management.
2025-10-16 10:16:48 -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
Matheus Demoner
6091d2ce6b Merge pull request #23 from Aignosi/SIENTIAPDE-1222-ajustar-a-library-para-fazer-o-download-do-courier
SIENTIAPDE-1222: Enhance Orchestration, Notification Filtering, and Server Configuration
2025-09-24 12:22:31 -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
dacbcbf56a SIENTIAPDE-1222
Update .gitignore to include .env file and ensure git_log is tracked, improving project configuration management.
2025-09-24 10:37:05 -03:00
vitor-aignosi
ccd45d6bc2 Merge branch 'SIENTIAPDE-1222-ajustar-a-library-para-fazer-o-download-do-courier' of github.com:Aignosi/sientia-dataops-orchestrator_temporal into SIENTIAPDE-1222-ajustar-a-library-para-fazer-o-download-do-courier 2025-09-24 10:36:38 -03:00
vitor-aignosi
60cc55fdd0 SIENTIAPDE-1222
Remove .env file containing sensitive configuration details, enhancing security by eliminating hardcoded credentials.
2025-09-24 10:36:35 -03:00
vitor-aignosi
0991cc74ab Update run_local.sh
Co-authored-by: codeant-ai[bot] <151821869+codeant-ai[bot]@users.noreply.github.com>
2025-09-24 10:26:20 -03:00
vitor-aignosi
52fd68f469 Update orchestrator/workflows/subworkflows/process_notifications.py
Co-authored-by: codeant-ai[bot] <151821869+codeant-ai[bot]@users.noreply.github.com>
2025-09-24 10:26:09 -03:00
vitor-aignosi
c3f5ba660f SIENTIAPDE-1222
Enhance test cases for server configuration in test_formatters.py and test_orchestrator_functions.py

- Added optional fields for certificate paths in the test cases to align with recent changes in server configuration, improving test coverage and ensuring proper handling of security configurations.
2025-09-24 09:13:22 -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
e31c5eece1 SIENTIAPDE-1222
SIENTIAPDE-1222
Enhance tests for email and MongoDB activities

- Added a test for sending emails when no SMTP server is configured, ensuring proper handling of such cases.
- Updated MongoDB tests to include timestamp fields in the results, improving data accuracy in document retrieval.
- Modified connector configuration tests to reflect changes in SMTP server settings.
2025-09-16 17:36:39 -03:00
vitor-aignosi
dae585533c SIENTIAPDE-1222
Update image tag in values.yaml to version 0.4.6
2025-09-16 16:42:36 -03:00
vitor-aignosi
b816ad523b SIENTIAPDE-1222
Enhance README and activities with advanced notification filtering features

- Updated README to include new intelligent notification filtering capabilities, including TTL-based duplicate prevention and ignore lists.
- Enhanced `Formatters` activity to support notification filtering for scheduled reports and added detailed filtering logic.
- Improved `SlotManager` to implement advanced notification filtering with persistent alert detection and group-based filtering.
- Updated `Alerts` workflow to incorporate intelligent filtering for real-time error notifications, ensuring efficient alert delivery.
2025-09-16 16:36:32 -03:00
vitor-aignosi
1f8d3e8777 SIENTIAPDE-1222
Update GITHUB_BRANCH in values.yaml to reflect new task for downloading the courier
2025-09-16 15:24:04 -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
Bruno Domingues
5db411e5b5 Merge pull request #21 from Aignosi/SIENTIAPDE-1182-ajustar-laborious-para-pegar-timestamp-da-resposta-do-mlflow
Fix: Handle empty receiver groups in Alerts workflow and add corresponding test
2025-09-05 13:38:31 -03:00
vitor-aignosi
d9dad61d9c Merge branch 'main' into SIENTIAPDE-1182-ajustar-laborious-para-pegar-timestamp-da-resposta-do-mlflow 2025-09-05 12:58:20 -03:00
vitor-aignosi
678c149cf2 SIENTIAPDE-1182
Add test for handling cases with no receiver groups in Alerts workflow

- Implemented a new test case to verify the behavior of the Alerts workflow when no receiver groups are provided, ensuring that the workflow executes correctly without unnecessary processing.
2025-09-05 12:57:59 -03:00
vitor-aignosi
c4733f4daa SIENTIAPDE-1182
SIENTIAPDE-1206: Add early return for empty receiver groups in Alerts workflow

- Implemented an early return in the Alerts class to handle cases where no receiver groups are provided, preventing unnecessary processing in the notification workflow.
2025-09-05 12:43:39 -03:00
Bruno Domingues
28382c2190 Merge pull request #20 from Aignosi/SIENTIAPDE-1182-ajustar-laborious-para-pegar-timestamp-da-resposta-do-mlflow
SIENTIAPDE-1182: Update Environment Variables and Enhance Batch Prediction
2025-09-05 10:35: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
Bruno Domingues
27ac78e769 Merge pull request #19 from Aignosi/SIENTIAPDE-1084-ajustar-documentacao
Refactor and Enhance Prediction Batch Processing, Documentation, and Cleanup Deprecated Code
2025-09-03 13:35:18 +00:00
vitor-aignosi
deeb6a6d2f SIENTIAPDE-1084
Remove outdated module docstrings from orchestrator and activities packages for improved clarity and maintenance.
2025-09-01 15:51:39 -03:00
vitor-aignosi
8d0b6c1222 Merge branch 'SIENTIAPDE-1084-ajustar-documentacao' of github.com:Aignosi/sientia-dataops-orchestrator_temporal into SIENTIAPDE-1084-ajustar-documentacao 2025-09-01 15:50:02 -03:00
vitor-aignosi
fc1358713c SIENTIAPDE-1182
Update README.md to enhance system architecture documentation

- Removed outdated system overview diagram and replaced it with updated architecture diagrams for workflows, including Data Loading, Processing, and Notifications.
- Added detailed architecture sections for the Alerts and Reports workflows, including input parameters and flowcharts to illustrate processes.
- Improved clarity and organization of the README to better reflect the current system design and functionality.
2025-09-01 15:49:44 -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
93e50883c1 SIENTIAPDE-1182
Update README.md to enhance system architecture documentation

- Removed outdated system overview diagram and replaced it with updated architecture diagrams for workflows, including Data Loading, Processing, and Notifications.
- Added detailed architecture sections for the Alerts and Reports workflows, including input parameters and flowcharts to illustrate processes.
- Improved clarity and organization of the README to better reflect the current system design and functionality.
2025-09-01 09:19:46 -03:00
vitor-aignosi
3724ea2bc8 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-08-29 16:13:57 -03:00
Bruno Domingues
d701943586 Merge pull request #18 from Aignosi/SIENTIAPDE-1205-alterar-opc-para-assincrono
SIENTIAPDE-1205: Standardize Datetime Handling in MongoDB Activities and Update Orchestration Notebook
2025-08-29 14:00:17 +00:00
vitor-aignosi
e389bd7c27 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-08-28 16:32:06 -03:00
vitor-aignosi
8f49745b0a SIENTIAPDE-1205
SIENTIAPDE-1205: Update timestamp formatting in MongoDB tests

- Modified timestamp handling in test_mongo_db.py to utilize DATETIME_FORMAT_MS_WITH_TZ for consistent formatting across test cases.
- Ensured all timestamp strings include UTC timezone information for improved accuracy in datetime comparisons.
2025-08-28 09:00:39 -03:00
vitor-aignosi
fbf006bb99 SIENTIAPDE-1205
SIENTIAPDE-1205: Update timestamp handling in MongoDB activities

- Modified timestamp formatting in mongo_db.py to apply UTC timezone before string conversion, ensuring consistency with DATETIME_FORMAT_MS_WITH_TZ.
2025-08-27 09:37:45 -03:00
vitor-aignosi
90e9e571b2 SIENTIAPDE-1205
SIENTIAPDE-1205: Simplify timestamp formatting in MongoDB activities

- Removed timezone conversion from timestamp handling in mongo_db.py, streamlining the formatting process while maintaining consistency with DATETIME_FORMAT_MS_WITH_TZ.
2025-08-27 09:35:55 -03:00
vitor-aignosi
2a3e5b8bc4 SIENTIAPDE-1205
SIENTIAPDE-1205: Refactor timestamp handling in MongoDB activities

- Updated the import statement in mongo_db.py to include timezone support.
- Modified timestamp formatting to ensure UTC timezone is applied before string conversion, enhancing consistency in datetime handling.
2025-08-27 09:32:42 -03:00