+1 -1

README.md

reviewed

··· 1 1 # ROOST - Osprey 2 2 3 3 - <img width="36" height="46" alt="Copy of ROOST-Mark-Yellow" src="/images/ROOST-Horizontal-Yellow .png" /> 3 3 + <img width="150" height="191" alt="Copy of ROOST-Mark-Yellow" src="/images/ROOST-Horizontal-Yellow .png" /> 4 4 5 5 # Welcome to Osprey 6 6

+1 -1

example_data/template.json

reviewed

··· 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"}}}} 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"}}}}

-1

osprey_rpc/src/osprey/rpc/common/v1/execution_result_pb2_grpc.py

reviewed

··· 1 1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2 2 """Client and server classes corresponding to protobuf-defined services.""" 3 3 import grpc 4 4 -

-1

osprey_rpc/src/osprey/rpc/common/v1/take_data_pb2_grpc.py

reviewed

··· 1 1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2 2 """Client and server classes corresponding to protobuf-defined services.""" 3 3 import grpc 4 4 -

-1

osprey_rpc/src/osprey/rpc/common/v1/verdicts_pb2_grpc.py

reviewed

··· 1 1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2 2 """Client and server classes corresponding to protobuf-defined services.""" 3 3 import grpc 4 4 -

-1

osprey_rpc/src/osprey/rpc/pigeon/v1/options_pb2_grpc.py

reviewed

··· 1 1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2 2 """Client and server classes corresponding to protobuf-defined services.""" 3 3 import grpc 4 4 -

-1

osprey_worker/src/osprey/worker/lib/utils/dates.py

reviewed

··· 4 4 5 5 import pytz 6 6 from dateutil import parser 7 7 - from osprey.worker.lib.singletons import CONFIG 8 7 from pytz import UTC 9 8 10 9 OSPREY_EPOCH = 1420070400000

-1

osprey_worker/src/osprey/worker/sinks/sink/kafka_output_sink.py

reviewed

··· 2 2 3 3 import sentry_sdk 4 4 from kafka import KafkaProducer 5 5 - 6 5 from osprey.engine.executor.execution_context import ExecutionResult 7 6 from osprey.worker.lib.osprey_shared.logging import get_logger 8 7 from osprey.worker.sinks.sink.output_sink import BaseOutputSink

+1 -1

osprey_worker/src/osprey/worker/sinks/sink/osprey_coordinator_input_stream.py

reviewed

··· 17 17 ClientDetails, 18 18 Disconnect, 19 19 Nack, 20 20 - Request, 21 20 OspreyCoordinatorAction, 21 21 + Request, 22 22 ) 23 23 from osprey.rpc.osprey_coordinator.bidirectional_stream.v1.service_pb2_grpc import ( 24 24 OspreyCoordinatorServiceStub,