apalis-dev / apalis-dev/apalis-pgmq

[Bug](workflow): Delay Operators in workflows dont work

Open
#30 0 comments 0 reactions 1 assignee Claimed by @geofmureithi View on GitHub
bug good first issue
Dominant language
Rust
Stars
2
Forks
1
PR merge metrics
No merged PRs in 30d

Description

### What happened?

Say I have such a workflow:

```rs
let workflow = Workflow::new("test_workflow")
.and_then(task1)
.delay_for(delay)
.and_then(task2)
.and_then(task3);
```

### Expected behavior

The workflow should delay for the specified period

### Steps to reproduce

1. Setup
2. Run the workflow
3. The workflow hangs

### Minimal code example

```rust
let workflow = Workflow::new("test_workflow")
.and_then(task1)
.delay_for(delay)
.and_then(task2)
.and_then(task3);
```

### Version

Other (specify in additional context)

### Environment

- OS:
- Rust version:
- Cargo version:

### Relevant log output

```shell

```

### Additional context

_No response_

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.