Skip to content

Commit a102a48

Browse files
committed
merge master and fix conflict
Signed-off-by: nikki everett <[email protected]>
2 parents e033a19 + 24b60b3 commit a102a48

File tree

42 files changed

+983
-214
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

42 files changed

+983
-214
lines changed

docs/content/api/modules.json.gz

996 Bytes
Binary file not shown.

docs/content/api/searchindex.json.gz

-4 Bytes
Binary file not shown.

docs/content/api/sections.json.gz

64 Bytes
Binary file not shown.

docs/content/integrations/looker.mdx

+5-3
Original file line numberDiff line numberDiff line change
@@ -93,8 +93,8 @@ By default, Dagster will generate asset specs for each Looker asset based on its
9393
```python file=/integrations/looker/customize-looker-assets.py
9494
from dagster_looker import (
9595
DagsterLookerApiTranslator,
96+
LookerApiTranslatorStructureData,
9697
LookerResource,
97-
LookerStructureData,
9898
LookerStructureType,
9999
load_looker_asset_specs,
100100
)
@@ -109,7 +109,9 @@ looker_resource = LookerResource(
109109

110110

111111
class CustomDagsterLookerApiTranslator(DagsterLookerApiTranslator):
112-
def get_asset_spec(self, looker_structure: LookerStructureData) -> dg.AssetSpec:
112+
def get_asset_spec(
113+
self, looker_structure: LookerApiTranslatorStructureData
114+
) -> dg.AssetSpec:
113115
# We create the default asset spec using super()
114116
default_spec = super().get_asset_spec(looker_structure)
115117
# We customize the team owner tag for all assets,
@@ -125,7 +127,7 @@ class CustomDagsterLookerApiTranslator(DagsterLookerApiTranslator):
125127

126128

127129
looker_specs = load_looker_asset_specs(
128-
looker_resource, dagster_looker_translator=CustomDagsterLookerApiTranslator
130+
looker_resource, dagster_looker_translator=CustomDagsterLookerApiTranslator()
129131
)
130132
defs = dg.Definitions(assets=[*looker_specs], resources={"looker": looker_resource})
131133
```

docs/content/integrations/powerbi.mdx

+2-1
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,8 @@ class MyCustomPowerBITranslator(DagsterPowerBITranslator):
122122

123123

124124
power_bi_specs = load_powerbi_asset_specs(
125-
power_bi_workspace, dagster_powerbi_translator=MyCustomPowerBITranslator
125+
power_bi_workspace,
126+
dagster_powerbi_translator=MyCustomPowerBITranslator,
126127
)
127128
defs = dg.Definitions(
128129
assets=[*power_bi_specs], resources={"power_bi": power_bi_workspace}

docs/content/integrations/tableau.mdx

+2-1
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,8 @@ class MyCustomTableauTranslator(DagsterTableauTranslator):
143143

144144

145145
tableau_specs = load_tableau_asset_specs(
146-
tableau_workspace, dagster_tableau_translator=MyCustomTableauTranslator
146+
tableau_workspace,
147+
dagster_tableau_translator=MyCustomTableauTranslator,
147148
)
148149
defs = dg.Definitions(assets=[*tableau_specs], resources={"tableau": tableau_workspace})
149150
```

docs/docs-beta/CONTRIBUTING.md

+3-3
Original file line numberDiff line numberDiff line change
@@ -96,9 +96,9 @@ Before:
9696

9797
After:
9898

99-
| Key | Value |
100-
|---|---|
101-
| `DAGSTER_CLOUD_DEPLOYMENT_NAME` | The name of the Dagster+ deployment. <br/><br/> **Example:** `prod`. |
99+
| Key | Value |
100+
| ------------------------------------ | --------------------------------------------------------------------------------------------------------- |
101+
| `DAGSTER_CLOUD_DEPLOYMENT_NAME` | The name of the Dagster+ deployment. <br/><br/> **Example:** `prod`. |
102102
| `DAGSTER_CLOUD_IS_BRANCH_DEPLOYMENT` | `1` if the deployment is a [branch deployment](/dagster-plus/features/ci-cd/branch-deployments/index.md). |
103103

104104
#### Line breaks and lists in tables

docs/docs-beta/docs/dagster-plus/deployment/management/settings/customizing-agent-settings.md

+129-1
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,136 @@ sidebar_position: 80
44
unlisted: true
55
---
66

7-
{/* TODO move from https://docs.dagster.io/dagster-plus/deployment/agents/customizing-configuration */}
7+
:::note
8+
This guide is applicable to Dagster+.
9+
:::
10+
11+
{/* /deployment/dagster-instance */}
12+
The Dagster+ Agent is a special variant of the Dagster instance used in [Dagster Open Source](/todo.md) and is configured through the same `dagster.yaml` file. You can customize your agent with these settings.
13+
14+
:::note
15+
{/* /dagster-plus/deployment/agents/kubernetes/configuring-running-kubernetes-agent */}
16+
For [Kubernetes agents](/todo.md) deployed with the Dagster+ Helm chart, you'll need to refer to the Helm chart's config map for customizing the agent.
17+
:::
18+
19+
## Enabling user code server TTL
20+
21+
User code servers support a configurable time-to-live (TTL). The agent will spin down any user code servers that haven't served requests recently and will spin them back up the next time they're needed. Configuring TTL can save compute cost because user code servers will spend less time sitting idle.
22+
23+
To configure TTL:
24+
```yaml
25+
# dagster.yaml
26+
instance_class:
27+
module: dagster_cloud.instance
28+
class: DagsterCloudAgentInstance
29+
30+
dagster_cloud_api:
31+
agent_token:
32+
env: DAGSTER_CLOUD_AGENT_TOKEN
33+
deployment: prod
34+
35+
user_code_launcher:
36+
module: dagster_cloud.workspace.docker
37+
class: DockerUserCodeLauncher
38+
config:
39+
server_ttl:
40+
enabled: true
41+
ttl_seconds: 7200 #2 hours
42+
```
43+
44+
## Streaming compute logs
45+
46+
You can set up streaming compute logs by configuring the log upload interval (in seconds).
47+
48+
```yaml
49+
# dagster.yaml
50+
instance_class:
51+
module: dagster_cloud.instance
52+
class: DagsterCloudAgentInstance
53+
54+
dagster_cloud_api:
55+
agent_token:
56+
env: DAGSTER_CLOUD_AGENT_TOKEN
57+
deployment: prod
58+
59+
user_code_launcher:
60+
module: dagster_cloud.workspace.docker
61+
class: DockerUserCodeLauncher
62+
63+
compute_logs:
64+
module: dagster_cloud
65+
class: CloudComputeLogManager
66+
config:
67+
upload_interval: 60
68+
```
869
970
## Disabling compute logs
1071
72+
<<<<<<< HEAD
1173
{/* NOTE this is a placeholder section so the Hybrid deployment index page has somewhere to link to */}
74+
=======
75+
You can disable forwarding compute logs to Dagster+ by configuring the `NoOpComputeLogManager` setting:
76+
77+
```yaml
78+
# dagster.yaml
79+
instance_class:
80+
module: dagster_cloud.instance
81+
class: DagsterCloudAgentInstance
82+
83+
dagster_cloud_api:
84+
agent_token:
85+
env: DAGSTER_CLOUD_AGENT_TOKEN
86+
deployment: prod
87+
88+
user_code_launcher:
89+
module: dagster_cloud.workspace.docker
90+
class: DockerUserCodeLauncher
91+
92+
compute_logs:
93+
module: dagster.core.storage.noop_compute_log_manager
94+
class: NoOpComputeLogManager
95+
```
96+
97+
## Writing compute logs to AWS S3
98+
99+
{/* /api/python-api/libraries/dagster-aws#dagster_aws.s3.S3ComputeLogManager */}
100+
You can write compute logs to an AWS S3 bucket by configuring the [dagster_aws.s3.compute_log_manager](/todo.md) module.
101+
102+
You are also able to stream partial compute log files by configuring the log upload interval (in seconds) using the `upload_interval` parameter.
103+
104+
Note: Dagster Labs will neither have nor use your AWS credentials. The Dagster+ UI will be able to show the URLs linking to the compute log files in your S3 bucket when you set the `show_url_only` parameter to `true`.
105+
106+
```yaml
107+
# dagster.yaml
108+
instance_class:
109+
module: dagster_cloud.instance
110+
class: DagsterCloudAgentInstance
111+
112+
dagster_cloud_api:
113+
agent_token:
114+
env: DAGSTER_CLOUD_AGENT_TOKEN
115+
deployment: prod
116+
117+
user_code_launcher:
118+
module: dagster_cloud.workspace.docker
119+
class: DockerUserCodeLauncher
120+
121+
compute_logs:
122+
module: dagster_aws.s3.compute_log_manager
123+
class: S3ComputeLogManager
124+
config:
125+
bucket: "mycorp-dagster-compute-logs"
126+
local_dir: "/tmp/cool"
127+
prefix: "dagster-test-"
128+
use_ssl: true
129+
verify: true
130+
verify_cert_path: "/path/to/cert/bundle.pem"
131+
endpoint_url: "http://alternate-s3-host.io"
132+
skip_empty_files: true
133+
upload_interval: 30
134+
upload_extra_args:
135+
ServerSideEncryption: "AES256"
136+
show_url_only: true
137+
region: "us-west-1"
138+
```
139+
>>>>>>> master

docs/docs-beta/docs/dagster-plus/deployment/management/settings/deployment-settings.md

+122-1
Original file line numberDiff line numberDiff line change
@@ -4,4 +4,125 @@ sidebar_position: 200
44
unlisted: true
55
---
66

7-
{/* TODO move from https://docs.dagster.io/dagster-plus/managing-deployments/deployment-settings-reference */}
7+
# Dagster+ deployment settings reference
8+
9+
:::note
10+
This guide is applicable to Dagster+.
11+
:::
12+
13+
{/* /dagster-plus */}
14+
This reference describes the settings that can be configured for full deployments in [Dagster+](/todo.md).
15+
16+
{/* /dagster-plus/managing-deployments/managing-deployments#configuring-deployment-settings */}
17+
Refer to the [Managing deployments in Dagster+ guide](/todo.md) for info about configuring settings in the Dagster+ interface or using the `dagster-cloud` CLI.
18+
19+
## Settings schema
20+
21+
Settings are formatted using YAML. For example:
22+
23+
```yaml
24+
run_queue:
25+
max_concurrent_runs: 10
26+
tag_concurrency_limits:
27+
- key: "database"
28+
value: "redshift"
29+
limit: 5
30+
31+
run_monitoring:
32+
start_timeout_seconds: 1200
33+
cancel_timeout_seconds: 1200
34+
max_runtime_seconds: 7200
35+
36+
run_retries:
37+
max_retries: 0
38+
39+
sso_default_role: EDITOR
40+
```
41+
42+
## Settings
43+
44+
For each deployment, you can configure settings for:
45+
46+
- [Run queue](#run-queue-run_queue)
47+
- [Run monitoring](#run-monitoring-run_monitoring)
48+
- [Run retries](#run-retries-run_retries)
49+
- [SSO default role](#sso-default-role)
50+
- [Non-isolated runs](#non-isolated-runs)
51+
52+
### Run queue (run_queue)
53+
54+
The `run_queue` settings allow you to specify how many runs can execute concurrently in the deployment.
55+
56+
```yaml
57+
run_queue:
58+
max_concurrent_runs: 10
59+
tag_concurrency_limits:
60+
- key: "database"
61+
value: "redshift"
62+
limit: 5
63+
```
64+
65+
| Property | Description |
66+
| --- | --- |
67+
| run_queue.max_concurrent_runs | The maximum number of runs that are allowed to be in progress at once. Set to 0 to stop any runs from launching. Negative values aren't permitted. <ul><li>**Default** - `10` (20 minutes)</li><li>**Maximum** - `500` <a href="/todo.md">(Hybrid)</a>, `50` <a href="/todo.md">(Serverless)</a></li></ul> |
68+
| run_queue.tag_concurrency_limits | A list of limits applied to runs with particular tags. <ul><li>**Defaults** - `[]`</li></ul> Each list item may have the following properties: <ul><li>`key`</li><li>`value`</li><ul><li>If defined, the `limit` is applied only to the `key-value` pair.</li><li>If set to a dict with applyLimitPerUniqueValue: true, the `limit` is applied to the number of unique values for the `key`.</li><li>If set to a dict with `applyLimitPerUniqueValue: true`, the limit is applied to the number of unique values for the `key`.</li></ul><li>`limit`</li></ul> |
69+
70+
### Run monitoring (run_monitoring)
71+
72+
The `run_monitoring` settings allow you to define how long Dagster+ should wait for runs to start before making them as failed, or to terminate before marking them as canceled.
73+
74+
```yaml
75+
run_monitoring:
76+
start_timeout_seconds: 1200
77+
cancel_timeout_seconds: 1200
78+
max_runtime_seconds: 7200
79+
```
80+
81+
| Property | Description |
82+
| --- | --- |
83+
| run_monitoring.start_timeout_seconds | The number of seconds that Dagster+ will wait after a run is launched for the process or container to start executing. After the timeout, the run will fail. This prevents runs from hanging in `STARTING` indefinitely when the process or container doesn't start. <ul><li>**Default** - `1200` (20 minutes)</li></ul> |
84+
| run_monitoring.cancel_timeout_seconds | The number of seconds that Dagster+ will wait after a run termination is initiated for the process or container to terminate. After the timeout, the run will move into a `CANCELED` state. This prevents runs from hanging in `CANCELING` indefinitely when the process or container doesn't terminate cleanly. <ul><li>**Default** - `1200` (20 minutes)</li></ul> |
85+
| run_monitoring.max_runtime_seconds | The number of seconds that Dagster+ will wait after a run is moved into a `STARTED` state for the run to complete. After the timeout, the run will be terminated and moved into a `FAILURE` state. This prevents runs from hanging in `STARTED` indefinitely if the process is hanging. <ul><li>**Default** - `No limit`</li></ul> |
86+
87+
### Run retries (run_retries)
88+
89+
The `run_retries` settings allow you to define how Dagster+ handles retrying failed runs in the deployment.
90+
91+
```yaml
92+
run_retries:
93+
max_retries: 0
94+
```
95+
96+
| Property | Descripton |
97+
| --- | --- |
98+
| run_retries.max_retries | The maximum number of times Dagster+ should attempt to retry a failed run. Dagster+ will use the default if this setting is undefined. <ul><li>**Default** - `0`</li></ul> |
99+
| run_retries.retry_on_asset_or_op_failure | Whether to retry runs that failed due to assets or ops in the run failing. Set this to false if you only want to retry failures that occur due to the run worker crashing or unexpectedly terminating, and instead rely on op or asset-level retry policies to retry assert or op failures. Setting this field to false will only change retry behavior for runs on dagster version 1.6.7 or greater. <ul><li>**Default** - `0`</li></ul> |
100+
101+
### SSO default role
102+
103+
{/* dagster-plus/account/managing-users/managing-user-roles-permissions#user-permissions-reference */}
104+
The `sso_default_role` setting lets you configure the default role on the deployment which is granted to new users that log in via SSO. For more information on available roles, see the [Dagster+ permissions reference](/todo.md).
105+
106+
```yaml
107+
sso_default_role: EDITOR
108+
```
109+
110+
| Property | Descripton |
111+
| --- | --- |
112+
| sso_default_role | If SAML SSO is enabled, this is the default role that will be assigned to Dagster+ users for this deployment. If SAML SSO is not enabled, this setting is ignored. <ul><li>**Default** - `Viewer`</li></ul> |
113+
114+
### Non-isolated runs
115+
116+
{/* /dagster-plus/deployment/serverless */}
117+
Configure [non-isolated runs](/todo.md) on your deployment.
118+
119+
```yaml
120+
non_isolated_runs:
121+
enabled: True
122+
max_concurrent_non_isolated_runs: 1
123+
```
124+
125+
| Property | Descripton |
126+
| --- | --- |
127+
| enabled | If enabled, the `Isolate run environment` checkbox will appear in the Launchpad. <ul><li>**Default** - `true`</li></ul> |
128+
| max_concurrent_non_isolated_runs | A limit for how many non-isolated runs to launch at once. Once this limit is reached, the checkbox will be greyed out and all runs will be isolated. This helps to avoid running out of RAM on the code location server. <ul><li>**Default** - `1`</li></ul> |

docs/docs-beta/docs/guides/build/create-asset-pipelines/metadata.md

+13
Original file line numberDiff line numberDiff line change
@@ -120,6 +120,19 @@ import Experimental from '../../../partials/\_Experimental.md';
120120

121121
<Experimental />
122122

123+
import Preview from '../../../partials/\_Preview.md';
124+
125+
<Preview />
126+
127+
import Beta from '../../../partials/\_Beta.md';
128+
129+
<Beta />
130+
131+
import Superseded from '../../../partials/\_Superseded.md';
132+
133+
<Superseded />
134+
135+
123136
To link assets with their source code, you can attach a **code reference**. Code references are a type of metadata that allow you to easily view those assets' source code from the Dagster UI, both in local development and in production.
124137

125138
:::tip

docs/docs-beta/docs/partials/_Beta.md

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
:::warning
2+
This feature is considered in a beta stage. It is still being tested and may change.
3+
:::
+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
:::warning
2+
This feature is considered in a preview stage and is under active development. It can change significantly, or be removed completely. It is not considered ready for production use.
3+
:::
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
:::warning
2+
This feature is considered superseded and is still available, but is no longer the best practice.
3+
:::

docs/docs-beta/docusaurus.config.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import {themes as prismThemes} from 'prism-react-renderer';
22
import type {Config} from '@docusaurus/types';
33
import type * as Preset from '@docusaurus/preset-classic';
4-
import { groupCollapsed } from 'console';
4+
import {groupCollapsed} from 'console';
55

66
const config: Config = {
77
title: 'Dagster Docs - Beta',

0 commit comments

Comments
 (0)