Filters jobs that are currently running. Returns: The filtered queryset.
(self, check_pending: bool = False, minutes_ago: int = 25)
| 392 | ) |
| 393 | |
| 394 | def running(self, check_pending: bool = False, minutes_ago: int = 25) -> "JobQuerySet": |
| 395 | """ |
| 396 | Filters jobs that are currently running. |
| 397 | |
| 398 | Returns: |
| 399 | The filtered queryset. |
| 400 | """ |
| 401 | qs = self.exclude(status__in=[status.value for status in self.model.STATUSES.final_statuses()]) |
| 402 | if not check_pending: |
| 403 | qs = qs.exclude(status=self.model.STATUSES.PENDING.value) |
| 404 | difference = now() - datetime.timedelta(minutes=minutes_ago) |
| 405 | return qs.filter(received_request_time__lte=difference) |
| 406 | |
| 407 | |
| 408 | class ParameterQuerySet(CleanOnCreateQuerySet): |
no test coverage detected