Hangfire ContinueWithJob 卡在等待状态，尽管父作业已成功

Question

我通过ContinueJobWith<MyHandler>(parentJobId, x => x.DoWork()) 一个接一个地执行了一些工作。

但是，第二个作业没有得到处理，并且始终处于 Awaiting 状态：

工作本身是这样的：

为什么会发生这种情况以及在哪里检查结果？

• 我们使用 Autofac 作为 DI 容器，但我们有自己的 JobActivator 实现，因为我们必须处理多租户。
• 我们使用 SQL Server 2019 进行存储。
• Hangfire 版本为 1.7.10
• 这是 MVC 5 应用程序
• 我没有在任何日志中或在调试期间看到任何错误/异常
• 通过this 之后，我已将此添加到我们的 Autofac 注册中

            builder.RegisterType<BackgroundJobStateChanger>()
                   .As<IBackgroundJobStateChanger>()
                   .InstancePerLifetimeScope();

这没什么区别。

这是作业的执行方式：

var parentJobId = _backgroundJobClient.Schedule<Handler>(h => h.ConvertCertToTraining(certId, command.SetUpOneToOneRelationship), TimeSpan.FromSeconds(1));
var filesCopyJObId = _backgroundJobClient.ContinueJobWith<Handler>(parentJobId, h => h.CopyAttachedFiles());
_backgroundJobClient.ContinueJobWith<Handler>(filesCopyJObId, h => h.NotifyUser(command.CertificationToBeConvertedIds, _principal.GetEmail()));

所有参数都是int、bool 或string。如果我手动将等待的作业排入队列，它们将毫无问题地执行。

我添加了 Hangfire 日志记录，但在那里看不到任何问题：服务器启动、停止、作业更改状态，但在那里看不到任何明显的错误。

我应该考虑哪些其他事情或者我应该在哪里/如何调试这个？

Answer 1

从外观上看，第一个 ID 为 216348 的作业已成功完成，但您的第二个 ID 为 216349 的作业正在等待父 ID 为 216347。根据 Hangfire 文档和经验，parentID 应该是您在执行第二个作业之前等待完成的作业。

根据Hangfire documentation on ContinueJobWith，“继续在其父作业完成时执行”。从您的屏幕截图中，不清楚 JobID 发生了什么：216347。一旦这项工作，216347 完成，ID 为 216349 的工作应该开始。如果您希望 216349 在 216348 完成后开始，请检查您的代码并确保将正确的 ParentID 传递给第二个作业。

---

更新

基于on this thread，将ContinuationsSupportAttribute 添加到您配置Hangfire 服务的GlobalJobFilters.Filter。这应该让您的 Hangfire 实例知道延续作业。

GlobalJobFilters.Filters.Add(new ContinuationsSupportAttribute());

Answer 2

在调查过程中，我们发现我们正在用我们自己的集合替换JobFilterProviderCollection：

    var filterProviderCollection = new JobFilterProviderCollection
    {
        new MyFilterProvider(...)
    };
    var backgroundJobClient = new BackgroundJobClient(JobStorage.Current, filterProviderCollection);

MyFilterProvider 看起来像这样：

    public IEnumerable<JobFilter> GetFilters(Job job)
    {
        return new JobFilter[]
        {
             new JobFilter(new HangfireTenantFilter(_tenantDetail, _principal), JobFilterScope.Global,  null),
             new JobFilter(new HangfireFunctionalityFilter(_functionalityFilter), JobFilterScope.Global, null),
        };
    }

事实证明，在 Continuation 上工作的代码只从这个过滤器集合中获取过滤器，ContinuationsSupportAttribute 没有在正确的时间在那里执行。因此，从GlobalJobFilters.Filters 重新添加默认的 Hangfire 过滤器修复了这种情况：

    public IEnumerable<JobFilter> GetFilters(Job job)
    {
        var customFilters = new List<JobFilter>()
        {
             new JobFilter(new HangfireTenantFilter(_tenantDetail, _principal), JobFilterScope.Global,  null),
             new JobFilter(new HangfireFunctionalityFilter(_functionalityFilter), JobFilterScope.Global, null),
        };
        customFilters.AddRange(GlobalJobFilters.Filters);

        return customFilters;
    }