@@ -484,7 +484,12 @@ def image_blur(
484484 ops .JSONValue (json_path = "$.status" )
485485 )
486486 results_df = bpd .DataFrame (
487- {"status" : blurred_status_series , "content" : dst }
487+ {
488+ "status" : blurred_status_series ,
489+ "content" : dst .blob .uri ().str .to_blob (
490+ connection = self ._resolve_connection (connection )
491+ ),
492+ }
488493 )
489494 results_struct = bbq .struct (results_df ).rename ("blurred_results" )
490495 return results_struct
@@ -618,7 +623,12 @@ def image_resize(
618623 ops .JSONValue (json_path = "$.status" )
619624 )
620625 results_df = bpd .DataFrame (
621- {"status" : resized_status_series , "content" : dst }
626+ {
627+ "status" : resized_status_series ,
628+ "content" : dst .blob .uri ().str .to_blob (
629+ connection = self ._resolve_connection (connection )
630+ ),
631+ }
622632 )
623633 results_struct = bbq .struct (results_df ).rename ("resized_results" )
624634 return results_struct
@@ -748,7 +758,9 @@ def image_normalize(
748758 results_df = bpd .DataFrame (
749759 {
750760 "status" : normalized_status_series ,
751- "content" : dst ,
761+ "content" : dst .blob .uri ().str .to_blob (
762+ connection = self ._resolve_connection (connection )
763+ ),
752764 }
753765 )
754766 results_struct = bbq .struct (results_df ).rename ("normalized_results" )
0 commit comments