getTask method

Future<QueueTask> getTask(
  1. String processId
)

Returns the persisted task for processId.

Implementation

Future<QueueTask> getTask(String processId) async {
  final database = await _ensureInitialized();
  final result = await database.query(
    tableName,
    where: 'process_id = ?',
    whereArgs: [processId],
    limit: 1,
  );

  if (result.isEmpty) {
    throw StateError('Queue task not found: $processId');
  }

  return QueueTask.fromMap(result.first);
}