[subscriber] New feature: job production within existing task