File tree Expand file tree Collapse file tree
control/cluster/calvin/scheduler/driver/core
data/executor/handlers/transaction Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -31,6 +31,7 @@ impl Scheduler {
3131 database_id : DatabaseId :: DEFAULT ,
3232 vshard_id : VShardId :: new ( self . vshard_id ) ,
3333 plan,
34+ // no-determinism: scheduler deadline controls waiting, not ordered state.
3435 deadline : Instant :: now ( )
3536 + Duration :: from_millis (
3637 self . config . epoch_duration_ms * u64:: from ( self . config . txn_deadline_multiplier ) ,
Original file line number Diff line number Diff line change @@ -75,6 +75,7 @@ impl CoreLoop {
7575 plan : PhysicalPlan :: Meta ( MetaOp :: Cancel {
7676 target_request_id : crate :: types:: RequestId :: new ( 0 ) ,
7777 } ) ,
78+ // no-determinism: ephemeral deadline is not written to Calvin state.
7879 deadline : std:: time:: Instant :: now ( ) + std:: time:: Duration :: from_secs ( 60 ) ,
7980 priority : crate :: bridge:: envelope:: Priority :: Normal ,
8081 trace_id : TraceId :: ZERO ,
Original file line number Diff line number Diff line change @@ -86,6 +86,7 @@ fn dummy_task() -> ExecutionTask {
8686 system_time : nodedb_types:: SystemTimeScope :: Current ,
8787 valid_at_ms : None ,
8888 } ) ,
89+ // no-determinism: test-only deadline is not written to Calvin state.
8990 deadline : Instant :: now ( ) + Duration :: from_secs ( 30 ) ,
9091 priority : Priority :: Normal ,
9192 trace_id : TraceId :: ZERO ,
Original file line number Diff line number Diff line change @@ -224,6 +224,7 @@ fn dummy_task() -> ExecutionTask {
224224 system_time : nodedb_types:: SystemTimeScope :: Current ,
225225 valid_at_ms : None ,
226226 } ) ,
227+ // no-determinism: test-only deadline is not written to Calvin state.
227228 deadline : Instant :: now ( ) + Duration :: from_secs ( 30 ) ,
228229 priority : Priority :: Normal ,
229230 trace_id : TraceId :: ZERO ,
You can’t perform that action at this time.
0 commit comments