Commit Graph

124 Commits

Author SHA1 Message Date
25f9d89317 SIENTIAPDE-1174
Update image tag to 0.3.1 in values.yaml and modify write_metrics method signature in Gates activity for improved type clarity.
2025-08-01 08:36:08 -03:00
fd740ca451 SIENTIAPDE-1174
Update Gates activity to use labels in LABORIOUS_DATA_WRITTEN_COUNT metric, improving clarity in metric tracking.
2025-07-31 16:34:55 -03:00
7ea9c1ce65 SIENTIAPDE-1174
Update Gates and Redis activities to use 'workflow_name' instead of 'pipeline_name' in metric tracking, ensuring consistency across the codebase.
2025-07-31 16:31:38 -03:00
b9c004827f SIENTIAPDE-1174
Update Redis activity to use metadata for model and pipeline names, improving consistency in metric tracking.
2025-07-31 16:27:18 -03:00
a8222359cc SIENTIAPDE-1174
Refactor Scouter class to remove pod_id reference, enhancing code clarity and consistency in data handling.
2025-07-31 16:25:02 -03:00
205810e882 SIENTIAPDE-1174
Update requirements for sientia-dataops-library to version 1.3.7, add ServiceMonitor configuration for Prometheus in values.yaml, and refactor pod_id usage in Gates and Redis activities for improved consistency in metric tracking.
2025-07-31 15:45:18 -03:00
c69ae5df03 SIENTIAPDE-1174
Remove unused getenv import from scouter.py to enhance code clarity and maintainability.
2025-07-31 14:59:12 -03:00
5d3eb74022 SIENTIAPDE-1174
SIENTIAPDE-1174 Add pod_id initialization in Activities class and update Scouter to reference it for improved consistency in environment variable handling.
2025-07-31 14:57:22 -03:00
ce20d86328 SIENTIAPDE-1174
Remove unused metrics import from core_scouter.py to streamline code and improve clarity.
2025-07-31 14:48:00 -03:00
b4827935a7 SIENTIAPDE-1174
Integrate write_metrics activity into CoreScouter for enhanced metric logging and update worker.py to include write_metrics in workflow tasks.
2025-07-31 14:43:34 -03:00
1c78cfb558 SIENTIAPDE-1174
Add write_metrics activity to Gates for database metric logging and import metrics module
2025-07-31 14:39:58 -03:00
7925b8a2ae SIENTIAPDE-1174
Update replica count in values.yaml, add application status metrics in metrics.py, and implement Prometheus server in worker.py for enhanced observability.
2025-07-31 13:01:39 -03:00
2efad30304 SIENTIAPDE-1174
SIENTIAPDE-1174 Update dependencies, modify image tag, and enhance metrics tracking in various activities for improved observability and performance.
2025-07-31 12:52:07 -03:00
b68b3b403b SIENTIAPDE-1151
SIENTIAPDE-1151 Filter data in Gates activity based on model tags to enhance data accuracy.
2025-07-21 12:03:03 -03:00
aacd52b5c7 SIENTIAPDE-1151
Add debug logging for collected data in MongoDB activity
2025-07-21 11:12:39 -03:00
b230ad614e SIENTIAPDE-1151
Update Redis set method to use a TTL of 5 hours for improved data retention.
2025-07-18 16:19:06 -03:00
95defccbf6 SIENTIAPDE-1163
Refactor notification handler imports across multiple files to use CoreNotificationHandler instead of NotificationHandler for consistency and clarity.
2025-07-16 08:59:21 -03:00
efeef628cb SIENTIAPDE-1148
Update sonar-project.properties to exclude worker.py from coverage, enhance error handling in worker.py, and add new tests for error scenarios in test_redis.py and test_mongo.py.
2025-07-11 12:32:23 -03:00
09d0569998 SIENTIAPDE-1141
Enhance worker configuration in worker.py by adding parameters for max concurrent tasks and cached workflows to improve performance and scalability.
2025-07-10 16:06:31 -03:00
1404eefdae SIENTIAPDE-1110
Update Gates activity to extract policy from filter configuration, improving clarity in filter handling.
2025-07-07 14:18:40 -03:00
f203ff829d SIENTIAPDE-1110
SIENTIAPDE-1110 Add store_data_package method to Redis activity for debug data storage functionality.
2025-07-07 10:57:52 -03:00
b95cc8ddd5 SIENTIAPDE-1110
Update CoreScouter workflow to include store_data_package method in the main execution flow, enhancing data handling capabilities.
2025-07-07 10:56:30 -03:00
0b77a7bc7e SIENTIAPDE-1110
Implement store_data_package method in Redis activity for debug data storage. Update CoreScouter workflow to conditionally call store_data_package based on debug flag. Enhance tests for store_data_package functionality and error handling.
2025-07-07 10:03:08 -03:00
08240efc8b SIENTIAPDE-1110
Enhance Gates and Redis activities by adding metadata parameter to apply_aggregation and notification methods. Refactor notification handling to use send_notification for improved consistency. Update tests to reflect changes in notification method calls and ensure proper functionality with new metadata integration.
2025-07-04 11:01:20 -03:00
d08d1b1337 SIENTIAPDE-1110
Refactor Activities class to remove Kafka and Druid dependencies, simplifying initialization. Update values.yaml to set replica count to 1 for reduced resource usage. Adjust Redis activity to set TTL to None for better data retention. Remove unused Kafka and Druid activity files and their associated tests, streamlining the codebase.
2025-07-03 16:25:55 -03:00
1dcba6b48e SIENTIAPDE-1110
Refactor Scouter workflow to update data loading method, changing from load_latest_druid_data to load_latest_data. Adjusted parameters for consistency in collection naming and improved clarity in data retrieval process.
2025-07-03 14:04:10 -03:00
208491498f SIENTIAPDE-1110
Update Druid configuration in values.yaml to change port from 8081 to 8888. Refactor pydruid.py to use druid_engine for SQLAlchemy connections, enhancing clarity and consistency in data loading operations.
2025-07-02 10:35:53 -03:00
6caec63977 SIENTIAPDE-1110
Refactor last data timestamp handling in Druid activity to use string format for default value, improving consistency in date representation.
2025-07-02 10:24:35 -03:00
3bbc6a6a79 SIENTIAPDE-1110
Update Druid activity to handle None values for last data timestamp, ensuring default timestamp is set to epoch start. Enhance data loading debug logging for improved traceability.
2025-07-02 10:21:55 -03:00
430fe04202 SIENTIAPDE-1110
Enhance Druid activity by adding configuration for Druid host and port in values.yaml. Refactor data loading logic to utilize SQLAlchemy for querying Druid, improving query efficiency and readability. Update timestamp handling to streamline data retrieval process.
2025-07-02 10:19:04 -03:00
5decb018d2 SIENTIAPDE-1110 2025-07-02 09:27:14 -03:00
879c1fdc49 SIENTIAPDE-1110
Add logging for data loading in Druid activity, enhancing traceability of data retrieval intervals.
2025-07-02 09:27:02 -03:00
c3c8e1b766 SIENTIAPDE-1110
Update Druid activity to handle None values for last data timestamp, ensuring robust date parsing. Bump image tag in values.yaml to 0.2.3 for version consistency.
2025-07-02 09:25:46 -03:00
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
91f2d8610b SIENTIAPDE-1110
Update MongoDB activity to format 'inserted_at' timestamps as strings in the format 'YYYY-MM-DD HH:MM:SS.ssssss', improving readability of timestamp data.
2025-07-01 16:09:46 -03:00
defac7b1f0 SIENTIAPDE-1110
Update Redis activity to include a specific prefix for the last data timestamp key, enhancing clarity in key management.
2025-07-01 16:06:52 -03:00
82ce1852e3 SIENTIAPDE-1110
Add debug logging for data filter in MongoDB activity to enhance traceability of filtering criteria.
2025-07-01 16:03:40 -03:00
b718801290 SIENTIAPDE-1110
Update get_last_data_timestamp method in Redis activity to return a string or None, improving type clarity for timestamp retrieval.
2025-07-01 15:53:47 -03:00
337a54217c SIENTIAPDE-1110
Fix aggregation function key in Gates activity from 'aggr_function' to 'aggr_func' for consistency in data processing.
2025-07-01 15:48:18 -03:00
0e915f5491 SIENTIAPDE-1110
Update Redis activity to include specific prefixes for keys in last data timestamp and held data, enhancing clarity in data management.
2025-07-01 15:45:03 -03:00
c9b9974f9d SIENTIAPDE-1110
Refactor Redis activity to remove unused 'ttl' parameter in set method, streamlining data handling.
2025-07-01 15:41:49 -03:00
f183bac90d SIENTIAPDE-1110
Enhance MongoDB data return format by converting to DataFrame dictionary, improving data structure for downstream processing.
2025-07-01 15:37:40 -03:00
f441873969 SIENTIAPDE-1110
Refactor MongoDB data retrieval to convert cursor to list, improving data handling and compatibility.
2025-07-01 15:33:51 -03:00
d7d44556c8 SIENTIAPDE-1110
Update MongoDB activity to handle None last_data_timestamp by using an empty filter, improving data retrieval logic.
2025-07-01 15:31:27 -03:00
1908741feb SIENTIAPDE-1110
Add debug logging for MongoDB data loading to enhance traceability of input data.
2025-07-01 15:26:57 -03:00
9b524ea428 SIENTIAPDE-1110
Refactor MongoDB activity to import datetime directly and format 'inserted_at' timestamps to ISO 8601 format for improved data consistency.
2025-07-01 15:20:50 -03:00
51f4eb1435 SIENTIAPDE-1110
Add new activities to worker.py for data management: load_latest_data, get_last_data_timestamp, and put_last_data_timestamp.
2025-07-01 15:16:55 -03:00
97d66ed6cd SIENTIAPDE-1110
Add MongoDB configuration to values.yaml and integrate MongoDB support in worker.py
2025-07-01 15:15:18 -03:00
53337de74a SIENTIAPDE-1110
SIENTIAPDE-1110 Add MongoDB integration and enhance Redis activity with timestamp management functions.
2025-07-01 15:10:32 -03:00
e7b05ebf3a SIENTIAPDE-1110
Add logging for consumer creation in Kafka activity to enhance traceability of topic management.
2025-07-01 11:05:03 -03:00