@@ -646,7 +646,7 @@ pub fn transform_conversational_json(
646
646
. is_some_and ( |v| v == "conversational" )
647
647
{
648
648
error ! (
649
- "ARRAY[]::JSONB inputs for transformer should only be used with a conversational task"
649
+ "ARRAY[]::JSONB inputs for transform should only be used with a conversational task"
650
650
) ;
651
651
}
652
652
match crate :: bindings:: transformers:: transform ( & task. 0 , & args. 0 , inputs) {
@@ -666,7 +666,7 @@ pub fn transform_conversational_string(
666
666
) -> JsonB {
667
667
if task != "conversational" {
668
668
error ! (
669
- "ARRAY[]::JSONB inputs for transformer should only be used with a conversational task"
669
+ "ARRAY[]::JSONB inputs for transform should only be used with a conversational task"
670
670
) ;
671
671
}
672
672
let task_json = json ! ( { "task" : task } ) ;
@@ -725,7 +725,7 @@ pub fn transform_stream_conversational_json(
725
725
. is_some_and ( |v| v == "conversational" )
726
726
{
727
727
error ! (
728
- "ARRAY[]::JSONB inputs for transformer_stream should only be used with a conversational task"
728
+ "ARRAY[]::JSONB inputs for transform_stream should only be used with a conversational task"
729
729
) ;
730
730
}
731
731
// We can unwrap this becuase if there is an error the current transaction is aborted in the map_err call
@@ -747,7 +747,7 @@ pub fn transform_stream_conversational_string(
747
747
) -> SetOfIterator < ' static , JsonB > {
748
748
if task != "conversational" {
749
749
error ! (
750
- "ARRAY::JSONB inputs for transformer_stream should only be used with a conversational task"
750
+ "ARRAY::JSONB inputs for transform_stream should only be used with a conversational task"
751
751
) ;
752
752
}
753
753
let task_json = json ! ( { "task" : task } ) ;
0 commit comments