Skip to content

Commit 7590b4c

Browse files
Update shared core (#170)
1 parent fdf2c63 commit 7590b4c

File tree

3 files changed

+15
-12
lines changed

3 files changed

+15
-12
lines changed

Cargo.lock

Lines changed: 3 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,4 +14,4 @@ doc = false
1414
[dependencies]
1515
pyo3 = { version = "0.25.1", features = ["extension-module"] }
1616
tracing-subscriber = { version = "0.3", features = ["fmt", "env-filter"] }
17-
restate-sdk-shared-core = { git = "https://github.com/restatedev/sdk-shared-core.git", rev = "eafbe4729a4ae7fa74fd0fb32e29121b240e1e5e", features = ["request_identity", "sha2_random_seed"] }
17+
restate-sdk-shared-core = { version = "=0.7.0", features = ["request_identity", "sha2_random_seed"] }

src/lib.rs

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -424,7 +424,7 @@ impl PyVM {
424424
) -> Result<PyNotificationHandle, PyVMError> {
425425
self_
426426
.vm
427-
.sys_state_get(key)
427+
.sys_state_get(key, Default::default())
428428
.map(Into::into)
429429
.map_err(Into::into)
430430
}
@@ -446,7 +446,7 @@ impl PyVM {
446446
) -> Result<(), PyVMError> {
447447
self_
448448
.vm
449-
.sys_state_set(key, buffer.as_bytes().to_vec().into())
449+
.sys_state_set(key, buffer.as_bytes().to_vec().into(), Default::default())
450450
.map_err(Into::into)
451451
}
452452

@@ -501,7 +501,7 @@ impl PyVM {
501501
.map(Into::into)
502502
.collect(),
503503
},
504-
buffer.as_bytes().to_vec().into(),
504+
buffer.as_bytes().to_vec().into(),Default::default()
505505
)
506506
.map(Into::into)
507507
.map_err(Into::into)
@@ -539,7 +539,8 @@ impl PyVM {
539539
.duration_since(SystemTime::UNIX_EPOCH)
540540
.expect("Duration since unix epoch cannot fail")
541541
+ Duration::from_millis(millis)
542-
}),
542+
})
543+
, Default::default()
543544
)
544545
.map(|s| s.invocation_id_notification_handle.into())
545546
.map_err(Into::into)
@@ -565,6 +566,7 @@ impl PyVM {
565566
.sys_complete_awakeable(
566567
id,
567568
NonEmptyValue::Success(buffer.as_bytes().to_vec().into()),
569+
Default::default()
568570
)
569571
.map_err(Into::into)
570572
}
@@ -576,7 +578,7 @@ impl PyVM {
576578
) -> Result<(), PyVMError> {
577579
self_
578580
.vm
579-
.sys_complete_awakeable(id, NonEmptyValue::Failure(value.into()))
581+
.sys_complete_awakeable(id, NonEmptyValue::Failure(value.into()), Default::default())
580582
.map_err(Into::into)
581583
}
582584

@@ -611,7 +613,7 @@ impl PyVM {
611613
.vm
612614
.sys_complete_promise(
613615
key,
614-
NonEmptyValue::Success(buffer.as_bytes().to_vec().into()),
616+
NonEmptyValue::Success(buffer.as_bytes().to_vec().into()),Default::default()
615617
)
616618
.map(Into::into)
617619
.map_err(Into::into)
@@ -624,7 +626,7 @@ impl PyVM {
624626
) -> Result<PyNotificationHandle, PyVMError> {
625627
self_
626628
.vm
627-
.sys_complete_promise(key, NonEmptyValue::Failure(value.into()))
629+
.sys_complete_promise(key, NonEmptyValue::Failure(value.into()),Default::default())
628630
.map(Into::into)
629631
.map_err(Into::into)
630632
}
@@ -699,7 +701,7 @@ impl PyVM {
699701
) -> Result<(), PyVMError> {
700702
self_
701703
.vm
702-
.sys_write_output(NonEmptyValue::Success(buffer.as_bytes().to_vec().into()))
704+
.sys_write_output(NonEmptyValue::Success(buffer.as_bytes().to_vec().into()),Default::default())
703705
.map_err(Into::into)
704706
}
705707

@@ -709,7 +711,7 @@ impl PyVM {
709711
) -> Result<(), PyVMError> {
710712
self_
711713
.vm
712-
.sys_write_output(NonEmptyValue::Failure(value.into()))
714+
.sys_write_output(NonEmptyValue::Failure(value.into()),Default::default())
713715
.map_err(Into::into)
714716
}
715717

0 commit comments

Comments
 (0)