From ba229a2d978f0b629461e5cf9b0b58e62e5bbece Mon Sep 17 00:00:00 2001 From: Juliet Shen Date: Mon, 15 Sep 2025 21:13:14 -0400 Subject: [PATCH] resize image and fix styling on doc names --- README.md | 2 +- example_data/template.json | 2 +- .../src/osprey/rpc/common/v1/execution_result_pb2_grpc.py | 1 - osprey_rpc/src/osprey/rpc/common/v1/take_data_pb2_grpc.py | 1 - osprey_rpc/src/osprey/rpc/common/v1/verdicts_pb2_grpc.py | 1 - osprey_rpc/src/osprey/rpc/pigeon/v1/options_pb2_grpc.py | 1 - osprey_worker/src/osprey/worker/lib/utils/dates.py | 1 - osprey_worker/src/osprey/worker/sinks/sink/kafka_output_sink.py | 1 - .../osprey/worker/sinks/sink/osprey_coordinator_input_stream.py | 2 +- 9 files changed, 3 insertions(+), 9 deletions(-) diff --git a/README.md b/README.md index 44e4ac0..aba45c7 100644 --- a/README.md +++ b/README.md @@ -1,6 +1,6 @@ # ROOST - Osprey -Copy of ROOST-Mark-Yellow +Copy of ROOST-Mark-Yellow # Welcome to Osprey diff --git a/example_data/template.json b/example_data/template.json index d4273e5..767095c 100644 --- a/example_data/template.json +++ b/example_data/template.json @@ -1 +1 @@ -{"send_time": "$timestamp","data": {"action_id": "$action_id","action_name": "create_post","data": {"user_id": "$user_id","ip_address": "$ip_address","event_type": "create_post","post": {"text": "$text"}}}} \ No newline at end of file +{"send_time": "$timestamp","data": {"action_id": "$action_id","action_name": "create_post","data": {"user_id": "$user_id","ip_address": "$ip_address","event_type": "create_post","post": {"text": "$text"}}}} diff --git a/osprey_rpc/src/osprey/rpc/common/v1/execution_result_pb2_grpc.py b/osprey_rpc/src/osprey/rpc/common/v1/execution_result_pb2_grpc.py index 2daafff..8a93939 100644 --- a/osprey_rpc/src/osprey/rpc/common/v1/execution_result_pb2_grpc.py +++ b/osprey_rpc/src/osprey/rpc/common/v1/execution_result_pb2_grpc.py @@ -1,4 +1,3 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc - diff --git a/osprey_rpc/src/osprey/rpc/common/v1/take_data_pb2_grpc.py b/osprey_rpc/src/osprey/rpc/common/v1/take_data_pb2_grpc.py index 2daafff..8a93939 100644 --- a/osprey_rpc/src/osprey/rpc/common/v1/take_data_pb2_grpc.py +++ b/osprey_rpc/src/osprey/rpc/common/v1/take_data_pb2_grpc.py @@ -1,4 +1,3 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc - diff --git a/osprey_rpc/src/osprey/rpc/common/v1/verdicts_pb2_grpc.py b/osprey_rpc/src/osprey/rpc/common/v1/verdicts_pb2_grpc.py index 2daafff..8a93939 100644 --- a/osprey_rpc/src/osprey/rpc/common/v1/verdicts_pb2_grpc.py +++ b/osprey_rpc/src/osprey/rpc/common/v1/verdicts_pb2_grpc.py @@ -1,4 +1,3 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc - diff --git a/osprey_rpc/src/osprey/rpc/pigeon/v1/options_pb2_grpc.py b/osprey_rpc/src/osprey/rpc/pigeon/v1/options_pb2_grpc.py index 2daafff..8a93939 100644 --- a/osprey_rpc/src/osprey/rpc/pigeon/v1/options_pb2_grpc.py +++ b/osprey_rpc/src/osprey/rpc/pigeon/v1/options_pb2_grpc.py @@ -1,4 +1,3 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc - diff --git a/osprey_worker/src/osprey/worker/lib/utils/dates.py b/osprey_worker/src/osprey/worker/lib/utils/dates.py index ff494df..d4af75b 100644 --- a/osprey_worker/src/osprey/worker/lib/utils/dates.py +++ b/osprey_worker/src/osprey/worker/lib/utils/dates.py @@ -4,7 +4,6 @@ from typing import Union import pytz from dateutil import parser -from osprey.worker.lib.singletons import CONFIG from pytz import UTC OSPREY_EPOCH = 1420070400000 diff --git a/osprey_worker/src/osprey/worker/sinks/sink/kafka_output_sink.py b/osprey_worker/src/osprey/worker/sinks/sink/kafka_output_sink.py index 5228211..83c0e76 100644 --- a/osprey_worker/src/osprey/worker/sinks/sink/kafka_output_sink.py +++ b/osprey_worker/src/osprey/worker/sinks/sink/kafka_output_sink.py @@ -2,7 +2,6 @@ from typing import Any import sentry_sdk from kafka import KafkaProducer - from osprey.engine.executor.execution_context import ExecutionResult from osprey.worker.lib.osprey_shared.logging import get_logger from osprey.worker.sinks.sink.output_sink import BaseOutputSink diff --git a/osprey_worker/src/osprey/worker/sinks/sink/osprey_coordinator_input_stream.py b/osprey_worker/src/osprey/worker/sinks/sink/osprey_coordinator_input_stream.py index 3446348..743cad6 100644 --- a/osprey_worker/src/osprey/worker/sinks/sink/osprey_coordinator_input_stream.py +++ b/osprey_worker/src/osprey/worker/sinks/sink/osprey_coordinator_input_stream.py @@ -17,8 +17,8 @@ from osprey.rpc.osprey_coordinator.bidirectional_stream.v1.service_pb2 import ( ClientDetails, Disconnect, Nack, - Request, OspreyCoordinatorAction, + Request, ) from osprey.rpc.osprey_coordinator.bidirectional_stream.v1.service_pb2_grpc import ( OspreyCoordinatorServiceStub, -- 2.51.2