TypeScript tasks.ActivityTask类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中simple-swf/build/src/tasks.ActivityTask类的典型用法代码示例。如果您正苦于以下问题：TypeScript ActivityTask类的具体用法？TypeScript ActivityTask怎么用？TypeScript ActivityTask使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了ActivityTask类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: buildTaskMeta

 buildTaskMeta(task: ActivityTask, meta?: Object): Object {
   let taskMeta = {
     task: { type: task.activityName(), id: task.id },
     workflow: task.getWorkflowInfo()
   }
   return _.defaults(taskMeta || {}, meta || {})
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:7，代码来源:ActivityWorker.ts

示例2: onTaskHeartbeat

 onTaskHeartbeat(task: ActivityTask, execution: Activity, status: TaskStatus) {
   const taskInfo = {type: task.activityName(), id: execution.id}
   this.ftlConfig.notifier.sendInfo('taskHeartbeat', {
     task: taskInfo,
     control: task.getControl(),
     workflow: task.getWorkflowInfo(),
     originWorkflow: task.getOriginWorkflow(),
     status
   })
   this.logInfo('task heartbeat status', this.buildTaskMeta(task, { status: status }))
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:11，代码来源:ActivityWorker.ts

示例3: onFinishedTask

 onFinishedTask(task: ActivityTask, execution: Activity, success: boolean, details: TaskStatus) {
   let startTime = this.activityTimers[task.id]
   const taskInfo = {type: task.activityName(), id: execution.id}
   this.ftlConfig.metricReporter.timing('activity.timer', startTime)
   this.ftlConfig.metricReporter.timing(`activity.byHandler.${task.activityName()}.timer`, startTime)
   this.ftlConfig.metricReporter.decrement('activity.running')
   this.ftlConfig.metricReporter.decrement(`activity.byHandler.${task.activityName()}.running`)
   delete this.activityTimers[task.id]
   this.logInfo('responded to activity task', { task: taskInfo, success: success })
   this.logDebug('finished task details', { task: taskInfo, success: success, details: details })
   this.emit('activityCompleted', task, execution, details)
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:12，代码来源:ActivityWorker.ts

示例4: onTaskError

 onTaskError(task: ActivityTask, execution: Activity, err: Error) {
   const taskInfo = {type: task.activityName(), id: execution.id}
   this.logInfo('unexpected task error', this.buildTaskMeta(task, { err }))
   this.ftlConfig.notifier.sendError('taskError', {
     task: taskInfo,
     control: task.getControl(),
     workflow: task.getWorkflowInfo(),
     originWorkflow: task.getOriginWorkflow(),
     err
   })
   this.emit('error', err, execution)
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:12，代码来源:ActivityWorker.ts

示例5: onTaskCompleted

 onTaskCompleted(task: ActivityTask, execution: Activity, details: TaskStatus) {
   const taskInfo = {type: task.activityName(), id: execution.id}
   this.ftlConfig.metricReporter.increment('activity.completed')
   this.ftlConfig.metricReporter.increment(`activity.byHandler.${task.activityName()}.completed`)
   this.ftlConfig.notifier.sendInfo('taskFinished', {
     task: taskInfo,
     control: task.getControl(),
     workflow: task.getWorkflowInfo(),
     originWorkflow: task.getOriginWorkflow(),
     details
   })
   this.logInfo('task completed', this.buildTaskMeta(task, { details: details }))
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:13，代码来源:ActivityWorker.ts

示例6: onTaskCanceled

 onTaskCanceled(task: ActivityTask, execution: Activity, reason: StopReasons) {
   const taskInfo = {type: task.activityName(), id: execution.id}
   this.ftlConfig.metricReporter.increment('activity.canceled')
   this.ftlConfig.metricReporter.increment(`activity.byHandler.${task.activityName()}.canceled`)
   delete this.activityTimers[task.id]
   this.ftlConfig.notifier.sendWarn('taskCanceled', {
     task: taskInfo,
     control: task.getControl(),
     workflow: task.getWorkflowInfo(),
     originWorkflow: task.getOriginWorkflow(),
     reason: reason
   })
   this.logInfo('task canceled', this.buildTaskMeta(task, { reason: reason }))
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:14，代码来源:ActivityWorker.ts

示例7: onStartTask

 onStartTask(task: ActivityTask, execution: Activity) {
   this.activityTimers[task.id] = new Date()
   this.ftlConfig.metricReporter.increment('activity.running')
   this.ftlConfig.metricReporter.increment(`activity.byHandler.${task.activityName()}.running`)
   const taskInfo = {task: {type: task.activityName(), id: execution.id}}
   this.logInfo('received activity task', taskInfo)
   execution.on('completed', this.onTaskCompleted.bind(this, task, execution))
   execution.on('failed', this.onTaskFailed.bind(this, task, execution))
   execution.on('canceled', this.onTaskCanceled.bind(this, task, execution))
   execution.on('error', this.onTaskError.bind(this, task, execution))
   execution.on('heartbeat', this.onTaskHeartbeat.bind(this, task, execution))
   execution.on('heartbeatComplete', this.onTaskHBComplete.bind(this, task, execution))
   this.ftlConfig.notifier.sendInfo('taskStarted', {
     task: taskInfo.task,
     control: task.getControl(),
     workflow: task.getWorkflowInfo(),
     originWorkflow: task.getOriginWorkflow()
   })
 }

开发者ID:instructure，项目名称:ftl-engine，代码行数:19，代码来源:ActivityWorker.ts

注：本文中的simple-swf/build/src/tasks.ActivityTask类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。