Auto triggered instances

Updated at:
Copy as MD

An auto triggered instance is a snapshot that is automatically generated based on the scheduling configuration of an auto triggered node. You can quickly view the instance details and perform related operations using the list view or the DAG.

Usage notes

  • Normal task: A task that actually runs code logic. This excludes dry-run tasks (such as tasks with the dry-run scheduling property, instances generated for a task outside its scheduled time, unselected branches of a branch node, or expired instances generated by converting real-time tasks to instances) and frozen tasks.

  • O&M environment: In a standard-mode workspace, you can switch between the development and production Operation Centers in the upper-left corner of the UI. Tasks are not automatically scheduled in the development Operation Center, so no auto triggered instances are generated on the Auto Triggered Instances page.

  • Task execution and troubleshooting:

    • A scheduled task runs only if its upstream tasks have successfully run, the scheduled time has been reached, sufficient scheduling resources are available, and the current task is not frozen. For more information, see Task execution conditions.

    • If a task is not running, first use the Upstream Analysis feature on the DAG page to quickly identify the key upstream tasks that are blocking the current task. Then, use the intelligent diagnosis feature to diagnose why the key instances are not running or identify existing issues. If the task has complex dependencies, this feature helps you quickly locate problems and improve O&M efficiency.

Limitations

  • Edition requirements

    DataWorks Professional Edition and higher provide the following advanced features to help you improve development and O&M efficiency.

    • Run Diagnostics: Quickly locate task execution issues. This feature is currently available for a free trial. For more information, see Intelligent diagnosis.

    • Advanced DAG analysis: Includes node aggregation, upstream analysis, and downstream analysis for clear insights into complex task lineage.

    • Export Query Results: Export data for external reports or further analysis.

    To experience all these features, we recommend upgrading to the Professional Edition. For more information, see Select and purchase a DataWorks edition.

  • Permissions

    Some operations can only be performed by users with O&M permissions. If a feature's entry point is grayed out or unavailable, go to the Management Center > Workspace > Workspace Members page to verify the user's O&M permissions. For more information, see Administration overview and Manage permissions on workspace-level services.

  • Feature limitations

    • You cannot manually delete an auto triggered instance. The platform automatically deletes the instance approximately 30 days after it expires. If a task no longer needs to run, you can freeze the instance.

    • For tasks run on a shared resource group for scheduling, instances are retained for one month (30 days), and logs are retained for one week (7 days).

    • For tasks run on a serverless resource group or an exclusive resource group for scheduling, both instances and logs are retained for one month (30 days).

    • For instances that have completed running, if the log size exceeds 3 MB, the platform automatically deletes them at a scheduled time each day.

Precautions

  • An auto triggered node generates an auto triggered instance at a scheduled time. Regardless of the instance generation method you choose, the instance always runs the latest code from the production environment.

  • To monitor a task, first set monitoring rules for it. For more information, see Smart monitoring overview. For a task with monitoring alerts configured, if it fails but you do not receive an alert notification, check whether you have configured your mobile number and email address on the Alert Contacts page. For more information, see Alert information.

  • The time an auto triggered instance is first generated depends on the instance generation method you choose. The methods include T +1 generated next day and Instant generation after publishing. For more information, see Instance generation methods.

    Note

    Manually rerunning a task does not trigger alerts based on custom rules.

Accessing the auto triggered instances page

  1. Go to the Operation Center page.

    Log on to the DataWorks console. In the top navigation bar, select the desired region. In the left-side navigation pane, choose Data Development and O&M > Operation Center. On the page that appears, select the desired workspace from the drop-down list and click Go to Operation Center.

  2. In the left-side navigation pane, choose Auto Triggered Task O&M > Scheduled Instance to go to the Auto Triggered Instances page.

    This page shows the running status of instances from different perspectives.

Instance perspective

Instance list

Intelligent search mode

With intelligent search, you can simply enter a query, and the system automatically parses it to filter for the required instances.

  1. Perform an intelligent search.

    Click the Intelligent Search button in the filter box. In the dialog box that appears, enter your search query, such as Sort by instance type, and press Enter. The system automatically displays matching instances.

  2. Save a new view.

    If you need to reuse the search criteria from your intelligent search, you can click Unsaved View > Save as New View in the search bar. In the Save View dialog box, enter a custom View Name and click Save. You can then find and use this new view from the view search bar.

    Note

    If you no longer want to use this view, find its name in the view search bar. Hover over the view name, click the ... icon on the right, and select Modify or Delete.

  3. Disable intelligent search.

    If you need to perform a precise search using filter conditions, you can press the Esc key or click the Disable Intelligent Search button in the instance actions bar to exit the intelligent search mode.

Filter conditions mode

Use filter conditions to precisely find the auto triggered instances you need.

  1. Simple filtering.

    In the toolbar, you can select multiple filter criteria, such as Search by task name, task ID, or instance ID, Scheduling Resource Group, Alerts Reported Within Last 24 Hours, or In Waiting for Resources State for a Long Period of Time, to filter instances.

  2. Advanced filtering.

    Click the Filter button in the filter box. You can then combine multiple criteria, such as Search by task name, task ID, or instance ID, Scheduling Resource Group, Run time, and Computing Resource Name, to accurately find the required instances.

Sorting mode

You can sort the auto triggered instance list in ascending or descending order by fields such as Data Timestamp, Priority, and Timing Time. For workflows that have run successfully, you can sort the internal tasks by Start Time, End Time, and Duration.

Manage auto triggered instances

Manage a single instance

To manage a specific auto triggered instance, find it in the list and use the actions in the Actions column. The following table describes the available actions.

Feature

Description

DAG

Displays the upstream and downstream dependencies of the auto triggered instance. You can perform related operations in the DAG. For more information, see Appendix: DAG features.

Run Diagnostics

Analyzes the full task dependency chain to diagnose why a task is not running as expected. For more information, see Intelligent diagnosis.

Rerun

Reruns an instance that is in a Successful or Failed state. When the task runs successfully, it triggers its un-run downstream tasks. This operation is commonly used to handle failed or missed nodes.

More

Rerun Descendent Nodes

Reruns the descendant nodes of a task that is in a Successful or Failed state. You can select which downstream tasks to rerun. After they run successfully, they can trigger their un-run downstream tasks. This operation is often used for data recovery.

Set to Successful

Sets the status of a failed task to successful. This is useful when you do not want a failed task to block its downstream tasks. This operation is often used to handle failed nodes.

Refresh Instance

Refreshes the current instance with the latest configurations for the following properties: computing resource, resource group, CUs, priority, image, scheduling type, rerun policy, timeout definition, owner, tags, and DQC configurations.

Terminate

Stops a task that you no longer need to run. The instance status changes to failed. You can only stop instances that are in the Waiting time, Waiting for resources, or Running state.

Freeze

Use this feature when the current instance and its downstream instances do not need to run. Freezing an auto triggered instance applies only to that specific instance. A frozen auto triggered instance will not be automatically scheduled to run (it will not process any data) and will block its downstream nodes from running.

Note
  • Do not operate on the projectname_root node, as it is the root node of the workspace. All auto triggered instances depend on this node. If you freeze this node, no auto triggered instances will run.

  • You cannot freeze an instance that is in the Waiting for resources, Waiting time, or Running state (for example, if the node code is running or a data quality check is in progress).

Unfreeze

Unfreezes a frozen instance.

  • If the instance has not yet run, it will run automatically after its upstream tasks are complete.

  • If all upstream tasks have already completed, the instance's status changes to failed. You must then manually rerun it.

Note

The unfreeze operation affects only the current instance. If the auto triggered node is still frozen, the instance generated the next day will also be frozen.

View Lineage

View the data lineage of the instance.

View cycle task details

View details of the auto triggered node corresponding to the instance.

View Runtime Log

After a task starts, you can view its detailed execution process in the runtime log. For descriptions of the core parameters in the log, see Appendix: Runtime log parameters.

Modify Scheduling Resource Group

Modifies the scheduling resource group used to run the current instance. This operation does not change the resource group of the auto triggered node to which the instance belongs.

Important

You cannot switch the resource group while the instance is waiting for resources. After the instance enters the waiting-for-resource state, you must first stop the task, then switch the resource group, and finally restart the instance.

Manage multiple instances

To manage multiple auto triggered instances at once, select the instances in the list. Then, use the bulk operation buttons at the bottom of the list to Terminate, Rerun, Set to Successful, Change Resource Group, Freeze, or Unfreeze them.

To export the list of instances from your search results, first perform a search. Then, click the Export Query Results button above the instance list. In the Export Query Results dialog box, confirm the following information:

  • Operation Object: Displays the number of instances matching the current filter criteria. You can click View Filter Conditions to see the specific filters.

  • Export Method: Select Export to Local File.

Note

Exporting is an asynchronous operation. After submitting the export task, you can go to the View Operation Center action records page to check the progress and download the result.

Instance DAG

Click DAG in the Actions column of an auto triggered instance to go to the DAG details page of the instance.

DAG page features

On the DAG details page of the instance, you can perform operations such as node aggregation, downstream analysis, and DAG display style adjustment.

Feature

Description

image

You can click the icons in the upper-left corner to aggregate instance information by the following dimensions:

  • Not Aggregate.

  • Aggregate by workspace.

  • Aggregate by owner.

  • Aggregate by priority.

image

If a task has many nodes or multiple levels, you can use the Upstream Analysis or Downstream Analysis feature to count the number of upstream and downstream tasks affected by the current task.

image

You can click the icons in the upper-right corner to adjust the display style of the DAG.

DAG actions

On the DAG details page, right-click an instance in the workflow to view details such as its upstream and downstream relationships and code. The following actions are available:

  • Show Ancestor Nodes: View the upstream tasks of the current node to understand which nodes affect its data output. You can expand ancestor nodes by level, up to six levels at a time.

  • Show Descendent Nodes: View the downstream tasks of the current node to understand which nodes are affected by its data output. You can expand descendant nodes by level, up to six levels at a time.

  • View Runtime Log: After a task starts, you can view its detailed execution process in the runtime log. For descriptions of the core parameters in the log, see Appendix: Runtime log parameters.

  • Run Diagnostics: Checks the task's upstream dependencies, scheduling time, scheduling resources, and running status.

  • View Code: View the code of the current node in the production environment. If it is not as expected, verify that the latest version of the node has been successfully deployed.

  • Edit Node: Opens the current node in DataStudio.

  • View Lineage: View the data lineage of the current instance.

  • More: View details such as the instance's basic properties, operation logs, and task code.

  • View auto triggered node: View information about the auto triggered node to which the current instance belongs.

  • Go to task 360 page: Go to the Data Governance Center to get a panoramic view of task details from multiple dimensions, such as associated baselines and instance run status, and perform task governance. For more information, see Get a panoramic view of a task.

  • Terminate: Stops a task that you no longer need to run. The task status will be set to failed. You can only stop instances that are in the Waiting time, Waiting for resources, or Running state.

  • Rerun: Reruns a task that is in a Successful or Failed state. After the task runs successfully, it can trigger its un-run downstream tasks. This is often used to handle failed or missed nodes.

  • Rerun Descendent Nodes: Reruns the descendant nodes of a task that is in a Successful or Failed state. You can select which downstream tasks to rerun. After they run successfully, they can trigger their un-run downstream tasks. This is often used for data recovery.

  • Set to Successful: Sets the status of a failed task to successful. This is useful when you do not want a failed task to block its downstream tasks. This is often used to handle failed nodes.

  • Resume: Resumes a failed task from the point of failure. If a task contains multiple SQL statements, it can resume from the specific SQL statement that failed.

    Note

    This operation is supported only for MaxCompute SQL tasks.

  • Trigger Data Quality Check: If data quality rules are configured for the task, you can trigger a validation check.

  • Emergency Operations: Emergency operations are single-use and affect only the current run of the node.

    • Delete Dependencies: Removes the dependency relationships for the current node. This is often used to urgently remove an upstream dependency when an upstream task fails but is not related to the data of the current instance, allowing the current task to run.

      Note

      You must confirm whether this action will affect your data by checking the task code and data lineage.

    • Change Priority: The priority of an instance is inherited from its baseline. You can reset the priority here as needed. A higher number indicates a higher priority.

    • Force Rerun: Forces a rerun of the current node. This can be done on auto triggered instances that are in successful, failed, or not-run states. This is often used for data recovery.

    • Force Heavy Run Downstream: Forcefully reruns downstream tasks to process data for the two preceding business dates. This operation is supported only for auto triggered instances in a Successful or Failed state and is often used for data recovery. For more information, see Appendix: Force rerun downstream.

      Note

      Only workspace administrators, tenant administrators, and Alibaba Cloud accounts can initiate a force rerun of downstream nodes.

    • Clone Instance: Creates a new clone instance based on a running instance (the host instance). The new instance is named in the format dw_clone_NodeName.

      Note
      • Only ODPS SQL node instances can be cloned, and each instance can be cloned only once.

      • Execution logic for host and clone instances:

        • Both the host and clone instances are in the running state. If the host instance succeeds first, the clone instance is stopped. If the clone instance succeeds first, the host instance is stopped and its status is set to successful.

        • If a downstream task of the current task has a clone instance, rerunning the downstream nodes will not trigger the execution of the clone instance.

  • Freeze: You can freeze an instance if it and its downstream instances do not need to run.

    Important
    • Freezing an upstream instance blocks its downstream instances from running. Proceed with caution.

    • Do not operate on the projectname_root node, as it is the root node of the workspace. All auto triggered instances depend on this node. If you freeze this node, no auto triggered instances will run.

    • You cannot freeze an instance that is in the Waiting for resources, Waiting time, or Running state (for example, if the node code is running or a data quality check is in progress).

  • Unfreeze: Unfreezes an instance that is in a frozen state.

    • If the instance has not yet run, it will run automatically after its upstream tasks are complete.

    • If all upstream tasks have already completed, the instance's status changes to failed. You must then manually rerun it.

    Note

    The unfreeze operation affects only the current instance. If the auto triggered node is still frozen, the instance generated the next day will also be frozen.

Instance details

In the instance DAG, left-click a specific instance and click View Log Data in the pop-up window, or click Show Details to view detailed information such as General, Runtime Log, Operation Log, and Code.

Tab

Description

General

This tab displays the task's scheduling properties in the production environment. For more information about the UI parameters, see: Scheduling configuration.

  • Relationship between Node ID and Instance ID:

    For nodes scheduled hourly or by the minute, you can use the node ID to locate all instances generated for that node on a given day. To locate a specific hourly or minute instance, use the instance ID for precise identification.

  • Task Status: The task status is related to its execution. If a task is in a Not-run, Waiting for Time, Waiting for Resource, or Frozen state, you can use Run Diagnostics to quickly identify the issue.

  • Time Spent Waiting for Resources: If a task waits for resources for a long time, you can use the Run Diagnostics feature to identify which other tasks are occupying resources and quickly troubleshoot the abnormal task.

  • Run Duration: If a task's run time is significantly longer than its historical average, you can handle it based on the following scenarios.

    • For non-synchronization tasks: Contact the person responsible for the corresponding compute engine.

    • For batch synchronization tasks: The task may be slow during a certain phase or waiting for resources for a long time. For more information, see Common issues with batch synchronization tasks.

  • Rule Monitoring: You can view the monitoring rules associated with the current instance. You can click Create on the right to quickly create a monitoring rule for the task's run status. For more information, see Manage rules.

    Note

    Here you can only view details of rules that monitor the task's run status, not data quality monitoring rules.

  • Baseline Monitoring: You can view the baselines associated with the current instance. You can click Create on the right to quickly create a baseline. For more information, see Manage baselines.

  • Tags: This section displays the custom tags you have defined in Tag Management. If the current node has governance issues, they will also be displayed as tags. You can go to the Data Governance Center to view details.

  • Maximum Parallel Instances: Shows the configured maximum number of parallel instances for the task, which can be Unlimited or a specific value (1 to 10,000). This setting limits the maximum number of instances of the same task that can run simultaneously, affecting auto triggered instances, backfill data instances, and test instances.

Runtime Log

After a task starts, you can view its detailed execution process in the runtime log. For descriptions of the core parameters in the log, see Appendix: Runtime log parameters.

Operation Log

View the operation records of a task or instance (time, operator, and specific action).

Code

View the latest code of the current task in the production environment. If it is not as expected, verify that the latest version of the task has been successfully deployed. For more information, see Deploy tasks.

Workflow perspective

Click the Workflow Perspective tab on the Scheduled Instance page to open the workflow O&M view.

Note

In the workflow perspective, only dependencies within the workflow are displayed. If there are dependencies across workflows or workspaces, switch to the Instance perspective to view them.

Workflow list

Feature

Description

Workflow run status overview

The Workflow column shows the run status of the workflow. The list view counts normal tasks, which excludes dry-run and frozen tasks. The DAG page displays all types of tasks.

  • 运行中: The number of running instances in the current workflow.

  • 成功: The number of successful instances in the current workflow.

  • 失败: The number of failed instances within the current workflow.

  • 其他: The number of instances in states other than the above within the current workflow.

Workflow O&M Actions

You can perform the following operations on a workflow:

  • DAG: View the DAG of the workflow. In the workflow perspective, hourly and minute-based tasks are grouped by default. Instance operations are the same as in the instance perspective. For more information, see DAG page features.

  • Rerun: Rerun all or specified tasks within the current workflow.

  • Terminate: Terminate the currently running workflow.

  • Freeze: Freeze the execution of the current workflow. After freezing, instances in this workflow will not run.

  • Unfreeze: Unfreeze a frozen workflow. After unfreezing, the workflow defaults to a failed state, and you can rerun it.

  • Set to Successful: Sets the current workflow to successful. After this, the nodes within the workflow show a successful status.

Appendix: Runtime log parameters

The runtime log shows the detailed execution process of a task. The following table describes the core log parameters.

Parameter

Description

SKYNET_ONDUTY

The task owner.

SKYNET_PARAVALUE

The list of scheduling parameters.

SKYNET_TASKID

The instance ID.

SKYNET_ID

The node ID.

SKYNET_NODENAME

The node name.

SKYNET_APPNAME

The workspace name.

SKYNET_REGION

The region where the workspace is located.

SKYNET_CYCTIME

The scheduled run time of the node.

FAQ

For more frequently asked questions, see Common issues.