Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: task after dag support #1342

Merged
merged 21 commits into from
Nov 4, 2022
Merged

feat: task after dag support #1342

Show file tree
Hide file tree
Changes from 15 commits
Commits
Show all changes
21 commits
Select commit Hold shift + click to select a range
75d6420
task after dag support
sfc-gh-swinkler Nov 4, 2022
b3470ab
dag for tasks
sfc-gh-swinkler Nov 4, 2022
93aa044
dag for tasks
sfc-gh-swinkler Nov 4, 2022
6d33c7a
dag for tasks
sfc-gh-swinkler Nov 4, 2022
aac8b13
dag for tasks
sfc-gh-swinkler Nov 4, 2022
4dbda48
dag for tasks
sfc-gh-swinkler Nov 4, 2022
6113170
dag for tasks
sfc-gh-swinkler Nov 4, 2022
8df7c31
dag for tasks
sfc-gh-swinkler Nov 4, 2022
f0df633
dag for tasks
sfc-gh-swinkler Nov 4, 2022
b2933ac
update task acceptance test
sfc-gh-swinkler Nov 4, 2022
21e5297
update task acceptance test
sfc-gh-swinkler Nov 4, 2022
c686c76
update task acceptance test
sfc-gh-swinkler Nov 4, 2022
607ec83
update dag task
sfc-gh-swinkler Nov 4, 2022
81ed9e5
update dag task
sfc-gh-swinkler Nov 4, 2022
3d26bf4
update dag task
sfc-gh-swinkler Nov 4, 2022
e90f848
update dag task
sfc-gh-swinkler Nov 4, 2022
560e235
update dag task
sfc-gh-swinkler Nov 4, 2022
dc8edd0
update dag task
sfc-gh-swinkler Nov 4, 2022
f7f15e0
update dag task
sfc-gh-swinkler Nov 4, 2022
288c7ad
update dag task
sfc-gh-swinkler Nov 4, 2022
9f3054b
update dag task
sfc-gh-swinkler Nov 4, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions docs/resources/task.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ description: |-
## Example Usage

```terraform
resource snowflake_task task {
resource "snowflake_task" "task" {
comment = "my task"

database = "db"
Expand All @@ -34,7 +34,7 @@ resource snowflake_task task {
enabled = true
}

resource snowflake_task serverless_task {
resource "snowflake_task" "serverless_task" {
comment = "my serverless task"

database = "db"
Expand All @@ -50,12 +50,12 @@ resource snowflake_task serverless_task {

user_task_timeout_ms = 10000
user_task_managed_initial_warehouse_size = "XSMALL"
after = "preceding_task"
after = [snowflake_task.task.name]
when = "foo AND bar"
enabled = true
}

resource snowflake_task test_task {
resource "snowflake_task" "test_task" {
comment = "task with allow_overlapping_execution"

database = "db"
Expand All @@ -81,7 +81,7 @@ resource snowflake_task test_task {

### Optional

- `after` (String) Specifies the predecessor task in the same database and schema of the current task. When a run of the predecessor task finishes successfully, it triggers this task (after a brief lag). (Conflict with schedule)
- `after` (List of String) Specifies one or more predecessor tasks for the current task. Use this option to create a DAG of tasks or add this task to an existing DAG. A DAG is a series of tasks that starts with a scheduled root task and is linked together by dependencies.
- `allow_overlapping_execution` (Boolean) By default, Snowflake ensures that only one instance of a particular DAG is allowed to run at a time, setting the parameter value to TRUE permits DAG runs to overlap.
- `comment` (String) Specifies a comment for the task.
- `enabled` (Boolean) Specifies if the task should be started (enabled) after creation or should remain suspended (default).
Expand Down
8 changes: 4 additions & 4 deletions examples/resources/snowflake_task/resource.tf
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
resource snowflake_task task {
resource "snowflake_task" "task" {
comment = "my task"

database = "db"
Expand All @@ -19,7 +19,7 @@ resource snowflake_task task {
enabled = true
}

resource snowflake_task serverless_task {
resource "snowflake_task" "serverless_task" {
comment = "my serverless task"

database = "db"
Expand All @@ -35,12 +35,12 @@ resource snowflake_task serverless_task {

user_task_timeout_ms = 10000
user_task_managed_initial_warehouse_size = "XSMALL"
after = "preceding_task"
after = [snowflake_task.task.name]
when = "foo AND bar"
enabled = true
}

resource snowflake_task test_task {
resource "snowflake_task" "test_task" {
comment = "task with allow_overlapping_execution"

database = "db"
Expand Down
Loading