cleanups

Author: MingweiSamuel

dfir_lang/src/graph/ops/fold.rs

@@ -50,7 +50,6 @@ pub const FOLD: OperatorConstraints = OperatorConstraints {
     input_delaytype_fn: |_| Some(DelayType::Stratum),
     write_fn: |wc @ &WriteContextArgs {
                    root,
-                   context,
                    op_span,
                    work_fn,
                    work_fn_async,
@@ -139,18 +138,9 @@ pub const FOLD: OperatorConstraints = OperatorConstraints {
             }
         };
 
-        let write_iterator_after = if let Persistence::Static | Persistence::Tick = persistence {
-            quote_spanned! {op_span=>
-                
-            }
-        } else {
-            Default::default()
-        };
-
         Ok(OperatorWriteOutput {
             write_prologue,
             write_iterator,
-            write_iterator_after,
             write_tick_end,
             ..Default::default()
         })

dfir_lang/src/graph/ops/join.rs

@@ -210,23 +210,12 @@ pub const JOIN: OperatorConstraints = OperatorConstraints {
             };
         };
 
-        let write_iterator_after =
-            if persistences[0] == Persistence::Static || persistences[1] == Persistence::Static {
-                quote_spanned! {op_span=>
-                    // TODO: Probably only need to schedule if #*_borrow.len() > 0?
-                    
-                }
-            } else {
-                quote_spanned! {op_span=>}
-            };
-
         Ok(OperatorWriteOutput {
             write_prologue: quote_spanned! {op_span=>
                 #lhs_prologue
                 #rhs_prologue
             },
             write_iterator,
-            write_iterator_after,
             write_tick_end: quote_spanned! {op_span=>
                 #lhs_tick_end
                 #rhs_tick_end

dfir_lang/src/graph/ops/join_fused.rs

@@ -113,7 +113,6 @@ pub const JOIN_FUSED: OperatorConstraints = OperatorConstraints {
     input_delaytype_fn: |_| Some(DelayType::Stratum),
     write_fn: |wc @ &WriteContextArgs {
                    root,
-                   context,
                    op_span,
                    work_fn_async,
                    ident,
@@ -170,23 +169,12 @@ pub const JOIN_FUSED: OperatorConstraints = OperatorConstraints {
             };
         };
 
-        let write_iterator_after =
-            if persistences[0] == Persistence::Static || persistences[1] == Persistence::Static {
-                quote_spanned! {op_span=>
-                    // TODO: Probably only need to schedule if #*_borrow.len() > 0?
-                    
-                }
-            } else {
-                quote_spanned! {op_span=>}
-            };
-
         Ok(OperatorWriteOutput {
             write_prologue: quote_spanned! {op_span=>
                 #lhs_prologue
                 #rhs_prologue
             },
             write_iterator,
-            write_iterator_after,
             write_tick_end: quote_spanned! {op_span=>
                 #lhs_tick_end
                 #rhs_tick_end

dfir_lang/src/graph/ops/join_fused_lhs.rs

@@ -127,23 +127,12 @@ pub const JOIN_FUSED_LHS: OperatorConstraints = OperatorConstraints {
             Persistence::Mutable => unreachable!(),
         };
 
-        let write_iterator_after =
-            if persistences[0] == Persistence::Static || persistences[1] == Persistence::Static {
-                quote_spanned! {op_span=>
-                    // TODO: Probably only need to schedule if #*_borrow.len() > 0?
-                    
-                }
-            } else {
-                quote_spanned! {op_span=>}
-            };
-
         Ok(OperatorWriteOutput {
             write_prologue: quote_spanned! {op_span=>
                 #lhs_prologue
                 #rhs_prologue
             },
             write_iterator,
-            write_iterator_after,
             write_tick_end: lhs_tick_end,
             ..Default::default()
         })

dfir_lang/src/graph/ops/reduce.rs

@@ -48,7 +48,6 @@ pub const REDUCE: OperatorConstraints = OperatorConstraints {
     input_delaytype_fn: |_| Some(DelayType::Stratum),
     write_fn: |wc @ &WriteContextArgs {
                    root,
-                   context,
                    op_span,
                    work_fn,
                    work_fn_async,
@@ -129,18 +128,9 @@ pub const REDUCE: OperatorConstraints = OperatorConstraints {
             }
         };
 
-        let write_iterator_after = if Persistence::Static == persistence {
-            quote_spanned! {op_span=>
-                
-            }
-        } else {
-            Default::default()
-        };
-
         Ok(OperatorWriteOutput {
             write_prologue,
             write_iterator,
-            write_iterator_after,
             write_tick_end,
             ..Default::default()
         })