@@ -756,7 +756,7 @@ def add_request(self, uid: str, request: Any, lit_api: LitAPI, lit_spec: Optiona
756756
757757 def mark_completed (self , uid : str ) -> None :
758758 """Mark a request as completed and remove it from the tracked state."""
759- logger .info (f"Marking sequence { uid } as completed" )
759+ logger .debug (f"Marking sequence { uid } as completed" )
760760 del self .active_sequences [uid ]
761761 del self .response_queue_ids [uid ]
762762
@@ -839,7 +839,7 @@ def prefill(
839839 if new_batches :
840840 # Add new requests to pending_requests and try to process them
841841 for response_queue_id , uid , input in new_batches :
842- logger .info (f"New request: { uid } , { input } " )
842+ logger .debug (f"New request: { uid } , { input } " )
843843 if self .has_capacity (lit_api ):
844844 self .add_request (uid , input , lit_api , lit_spec )
845845 self .response_queue_ids [uid ] = response_queue_id
@@ -892,6 +892,7 @@ def run(
892892 uid = step_output .uid
893893 response_queue_id = self .response_queue_ids [uid ]
894894
895+ response_data = lit_api .format_encoded_response (response_data )
895896 if status == LitAPIStatus .ERROR :
896897 self .put_error_response (response_queues , response_queue_id , uid , response_data )
897898 self .mark_completed (uid )
0 commit comments