Skip to content

Commit

Permalink
comments
Browse files Browse the repository at this point in the history
  • Loading branch information
lcouzens committed Jun 27, 2024
1 parent 1da7a87 commit c34d9a1
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 6 deletions.
4 changes: 2 additions & 2 deletions deploy/clowdapp.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -5642,10 +5642,10 @@ parameters:
- displayName: Provider count for batch polling
name: POLLING_BATCH_SIZE
value: "100"
- displayName: Timer to prevent triggering tasks while still processing
- displayName: Timer to prevent triggering tasks while still processing in days
name: PROCESSING_WAIT_TIMER
value: "3"
- displayName: Timer to prevent triggering tasks while still processing
- displayName: Timer to prevent triggering tasks while still processing in days
name: LARGE_PROCESSING_WAIT_TIMER
value: "7"
- displayName: Enable Tags Limit
Expand Down
4 changes: 2 additions & 2 deletions deploy/kustomize/base/base.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -515,10 +515,10 @@ parameters:
- displayName: Provider count for batch polling
name: POLLING_BATCH_SIZE
value: "100"
- displayName: Timer to prevent triggering tasks while still processing
- displayName: Timer to prevent triggering tasks while still processing in days
name: PROCESSING_WAIT_TIMER
value: "3"
- displayName: Timer to prevent triggering tasks while still processing
- displayName: Timer to prevent triggering tasks while still processing in days
name: LARGE_PROCESSING_WAIT_TIMER
value: "7"
- displayName: Enable Tags Limit
Expand Down
2 changes: 0 additions & 2 deletions koku/api/provider/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -92,8 +92,6 @@ def get_polling_batch(self, limit=-1, offset=0, filters=None):
if limit < 1:
# Django can't do negative indexing, so just return all the Providers.
# A limit of 0 doesn't make sense either. That would just return an empty QuerySet.
# Adding filter for data_updated_timestamp, prevent triggering new tasks if one is still in progress
# Additional 7 day check here if processing fails and data_updated_timestamp is not updated
return self.filter(**filters).exclude(polling_timestamp__gt=polling_delta)
return self.filter(**filters).exclude(polling_timestamp__gt=polling_delta)[offset : limit + offset]

Expand Down

0 comments on commit c34d9a1

Please sign in to comment.