Skip to content

Commit 2bac3d3

Browse files
committed
chore(su): upload message, assignment instead of bundle
1 parent 395af49 commit 2bac3d3

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

servers/su/src/domain/core/flows.rs

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -603,6 +603,9 @@ pub async fn write_item(
603603

604604
let aid = assignment.id();
605605
let did = data_item.id();
606+
let assignment_bytes = assignment
607+
.as_bytes()
608+
.map_err(|e| format!("{:?}", e))?;
606609
let build_result = builder.bundle_items(vec![assignment, data_item]).await?;
607610

608611
let process = Process::from_bundle(&build_result.bundle)?;
@@ -613,7 +616,8 @@ pub async fn write_item(
613616
.commit(&mut *schedule_info, &next_schedule_info, did, aid);
614617
drop(schedule_info);
615618

616-
upload(&deps, build_result.binary.to_vec()).await?;
619+
upload(&deps, input).await?;
620+
upload(&deps, assignment_bytes).await?;
617621

618622
return id_res(&deps, process.process.process_id.clone(), start_top_level);
619623
} else {
@@ -690,6 +694,9 @@ pub async fn write_item(
690694
None => None,
691695
};
692696

697+
let assignment_bytes = assignment
698+
.as_bytes()
699+
.map_err(|e| format!("{:?}", e))?;
693700
let build_result = builder.bundle_items(vec![assignment, data_item]).await?;
694701
let message = Message::from_bundle(&build_result.bundle)?;
695702

@@ -708,7 +715,8 @@ pub async fn write_item(
708715
.commit(&mut *schedule_info, &next_schedule_info, dtarget, aid);
709716
drop(schedule_info);
710717

711-
upload(&deps, build_result.binary.to_vec()).await?;
718+
upload(&deps, input).await?;
719+
upload(&deps, assignment_bytes).await?;
712720
return id_res(&deps, message.message_id()?, start_top_level);
713721
} else {
714722
return Err("Type tag not present".to_string());

0 commit comments

Comments
 (0)