expire method

  1. @override
Future<void> expire(
  1. String taskId,
  2. Duration ttl
)
override

Extends the TTL for a task status entry.

Implementation

@override
/// Extends the TTL for a task status entry.
Future<void> expire(String taskId, Duration ttl) async {
  final entry = _entries[taskId];
  if (entry == null) return;
  entry.expiresAt = stemNow().add(ttl);
  _scheduleExpiry(taskId, ttl);
}