Skip to content

Commit 47737e9

Browse files
fix(sqs): add ApproximateNumberOfMessagesDelayed to status and enqueued
1 parent 3c15eb8 commit 47737e9

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

taskqueue/aws_queue_api.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,11 @@ def _get_qurl(self, qurl):
7070
@property
7171
def enqueued(self):
7272
status = self.status()
73-
return int(status['ApproximateNumberOfMessages']) + int(status['ApproximateNumberOfMessagesNotVisible'])
73+
return (
74+
int(status['ApproximateNumberOfMessages'])
75+
+ int(status['ApproximateNumberOfMessagesNotVisible'])
76+
+ int(status['ApproximateNumberOfMessagesDelayed'])
77+
)
7478

7579
@property
7680
def inserted(self):
@@ -92,7 +96,11 @@ def is_empty():
9296
def status(self):
9397
resp = self.sqs.get_queue_attributes(
9498
QueueUrl=self.qurl,
95-
AttributeNames=['ApproximateNumberOfMessages', 'ApproximateNumberOfMessagesNotVisible']
99+
AttributeNames=[
100+
'ApproximateNumberOfMessages',
101+
'ApproximateNumberOfMessagesNotVisible',
102+
'ApproximateNumberOfMessagesDelayed'
103+
]
96104
)
97105
return resp['Attributes']
98106

0 commit comments

Comments
 (0)