File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -543,6 +543,7 @@ async fn process_csv_jsonl_file(
543543 split_avg : None ,
544544 base64_file : "" . to_string ( ) ,
545545 chunkr_create_task_req_payload : None ,
546+ webhook_url : None ,
546547 } ,
547548 csv_jsonl_worker_message. dataset_id ,
548549 web_pool. clone ( ) ,
Original file line number Diff line number Diff line change @@ -543,7 +543,7 @@ async fn upload_file(
543543 current_response. status_message =
544544 format ! ( "Processing page {}" , total_pages + 1 ) . into ( ) ;
545545 current_response. pages_processed = processed_pages. len ( ) as u32 ;
546- send_webhook ( & webhook_url, & current_response) . await ?;
546+ send_webhook ( webhook_url, & current_response) . await ?;
547547 }
548548
549549 for page in pages {
@@ -609,7 +609,7 @@ async fn upload_file(
609609 current_response. status_message =
610610 "Queuing chunks for creation" . to_string ( ) . into ( ) ;
611611 current_response. pages_processed = processed_pages. len ( ) as u32 ;
612- send_webhook ( & webhook_url, & current_response) . await ?;
612+ send_webhook ( webhook_url, & current_response) . await ?;
613613 }
614614
615615 create_file_chunks (
@@ -650,7 +650,7 @@ async fn upload_file(
650650 current_response. status_message =
651651 "Completed processing file" . to_string ( ) . into ( ) ;
652652 current_response. pages_processed = processed_pages. len ( ) as u32 ;
653- send_webhook ( & webhook_url, & current_response) . await ?;
653+ send_webhook ( webhook_url, & current_response) . await ?;
654654 }
655655 }
656656 }
You can’t perform that action at this time.
0 commit comments