Roey BermanandGitHub aebee7431a Hotfix outbound task predicate (#6455) ...

## What changed?

Cherry picked #6445 and added a change that prevents writing the new
predicate type

## Why?

To allow rolling back from 120 to 119 as well as from 119 to 118.

## How did you test it?

Ran and modified existing unit tests.

## Is hotfix candidate?

Yes, for 119.

2024-08-27 17:25:51 -07:00

..

queuestest

Adding documentation for dealing with DLQ messages (#5139)

2023-11-23 02:22:43 +00:00

action_pending_task_count.go

Use stdlib slices (#6018)

2024-07-26 16:42:24 -07:00

action_reader_stuck.go

Remove queue reader registration error handling logic (#5511)

2024-03-12 10:20:06 -07:00

action_slice_count.go

Use stdlib slices (#6018)

2024-07-26 16:42:24 -07:00

action_slice_predicate.go

Remove queue reader registration error handling logic (#5511)

2024-03-12 10:20:06 -07:00

action.go

Remove queue reader registration error handling logic (#5511)

2024-03-12 10:20:06 -07:00

active_standby_executor_test.go

Improve task executor interface (#4860)

2023-09-25 18:09:50 -07:00

active_standby_executor.go

Improve task executor interface (#4860)

2023-09-25 18:09:50 -07:00

alerts.go

Use int64 as type for queue readerID (#4176)

2023-04-21 15:59:44 -07:00

convert_test.go

Replace gogo/protobuf with google/protobuf (#5032)

2023-11-21 15:19:37 -08:00

convert.go

Hotfix outbound task predicate (#6455)

2024-08-27 17:25:51 -07:00

dlq_writer_test.go

Adding task category to dlq_writes metric (#5858)

2024-05-06 23:48:26 +00:00

dlq_writer.go

Adding task category to dlq_writes metric (#5858)

2024-05-06 23:48:26 +00:00

executable_factory.go

Config to specify error substrings to DLQ task processing errors (#5536)

2024-03-21 00:13:15 +00:00

executable_mock.go

Removed usused task version (#5821)

2024-05-06 11:38:20 -07:00

executable_test.go

Do not retry tasks that result in wrapped NotFound errors (#6244)

2024-07-05 15:31:11 -07:00

executable.go

Add error type and resource exhausted cause to task error metrics (#6306)

2024-08-09 13:54:04 +00:00

grouper_test.go

Hotfix outbound task predicate (#6455)

2024-08-27 17:25:51 -07:00

grouper.go

Hotfix outbound task predicate (#6455)

2024-08-27 17:25:51 -07:00

iterator_test.go

Remove history queue reader registration logic (#5420)

2024-02-20 14:44:38 -08:00

iterator.go

Remove history queue reader registration logic (#5420)

2024-02-20 14:44:38 -08:00

memory_scheduled_queue_test.go

Remove ExecutableWrapper (#5033)

2023-10-25 16:34:01 -07:00

memory_scheduled_queue.go

Update queue internals to use our new Metrics API (#5283)

2024-01-11 14:14:36 -08:00

metrics_test.go

Fix metric tag for delete execution task (#4275)

2023-05-03 13:26:19 -07:00

metrics.go

Fix state machine timer task metrics (#6286)

2024-07-15 10:05:49 -07:00

mitigator_test.go

Remove queue reader registration error handling logic (#5511)

2024-03-12 10:20:06 -07:00

mitigator.go

Remove queue reader registration error handling logic (#5511)

2024-03-12 10:20:06 -07:00

monitor_test.go

…

monitor.go

Fix typos in struct field / variable names (#4945)

2023-10-09 13:05:52 -04:00

priority_assigner_test.go

…

priority_assigner.go

Remove ExecutableWrapper (#5033)

2023-10-25 16:34:01 -07:00

queue_base_test.go

Config to specify error substrings to DLQ task processing errors (#5536)

2024-03-21 00:13:15 +00:00

queue_base.go

Update backoff package to support error-dependent and constant delay policies (#6068)

2024-06-17 19:31:40 +00:00

queue_immediate.go

Remove history queue reader registration logic (#5420)

2024-02-20 14:44:38 -08:00

queue_mock.go

…

queue_scheduled_test.go

Use stdlib slices (#6018)

2024-07-26 16:42:24 -07:00

queue_scheduled.go

Remove history queue reader registration logic (#5420)

2024-02-20 14:44:38 -08:00

queue.go

Revert back to using mockgen (#5656)

2024-04-03 17:06:32 +00:00

range_test.go

…

range.go

…

reader_group_test.go

Remove queue reader registration error handling logic (#5511)

2024-03-12 10:20:06 -07:00

reader_group.go

Replace golang.org/x/exp with stdlib where possible (#6366)

2024-08-01 19:33:04 +00:00

reader_quotas.go

Per-shard per-namespace rate limiter (#4302)

2023-05-16 09:24:45 -07:00

reader_test.go

Remove history queue reader registration logic (#5420)

2024-02-20 14:44:38 -08:00

reader.go

Update backoff package to support error-dependent and constant delay policies (#6068)

2024-06-17 19:31:40 +00:00

rescheduler_mock.go

…

rescheduler_test.go

Fix scheduled task rescheduling on failover (#5377)

2024-01-31 16:34:50 -08:00

rescheduler.go

Revert back to using mockgen (#5656)

2024-04-03 17:06:32 +00:00

scheduler_mock.go

Rate limited task scheduler (#4857)

2023-10-02 12:50:37 -07:00

scheduler_monitor.go

Update queue internals to use our new Metrics API (#5283)

2024-01-11 14:14:36 -08:00

scheduler_quotas.go

Rate limited task scheduler (#4857)

2023-10-02 12:50:37 -07:00

scheduler.go

Use DC subscription in fifo scheduler (#6316)

2024-07-22 13:37:54 -07:00

scheuduler_monitor_test.go

Rename metricDefinition getters to follow Go's guidelines (#5185)

2023-11-30 16:34:29 -08:00

scope_test.go

Use stdlib slices (#6018)

2024-07-26 16:42:24 -07:00

scope.go

…

slice_test.go

Use stdlib slices (#6018)

2024-07-26 16:42:24 -07:00

slice.go

Replace golang.org/x/exp with stdlib where possible (#6366)

2024-08-01 19:33:04 +00:00

speculative_workflow_task_timeout_executable.go

In memory timeout timer queue for speculative workflow task (#4254)

2023-05-09 13:00:15 -07:00

speculative_workflow_task_timeout_queue.go

In memory timeout timer queue for speculative workflow task (#4254)

2023-05-09 13:00:15 -07:00

test_util.go

Use stdlib slices (#6018)

2024-07-26 16:42:24 -07:00

tracker.go

Only update shard info when enough tasks are acked or time has passed (#5399)

2024-02-15 20:38:19 +00:00

util_test.go

Use int64 as type for queue readerID (#4176)

2023-04-21 15:59:44 -07:00

util.go

…