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.

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

[DOM-38846] - Bump apache-airflow from 1.10.15 to 2.2.4 #134

Merged
merged 3 commits into from
Jun 24, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ All notable changes to the `python-domino` library will be documented in this fi
* implemented pre-commit for black / flake8 formatting.

### Changed
* updated airflow dependency 2.2.4
* Updated runs_stdout output

## 1.0.8
Expand Down
22 changes: 11 additions & 11 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ List the runs on the selected project.

<hr>

### runs*start(\_command, isDirect, commitId, title, tier, publishApiEndpoint*)
### runs_start(\_command, isDirect, commitId, title, tier, publishApiEndpoint*)

Start a new run on the selected project. The parameters are:

Expand All @@ -93,7 +93,7 @@ Start a new run on the selected project. The parameters are:

<hr>

### runs*start_blocking(\_command, isDirect, commitId, title, tier, publishApiEndpoint, poll_freq=5, max_poll_time=6000*)
### runs_start_blocking(\_command, isDirect, commitId, title, tier, publishApiEndpoint, poll_freq=5, max_poll_time=6000*)

Same as method `run_start` except make a blocking request that waits until job is finished.

Expand All @@ -119,15 +119,15 @@ Stop an existing run in the selected project. The parameters are:

<hr>

### runs*stdout(\_runId*)
### runs_stdout(\_runId*)

Get stdout emitted by a particular run. The parameters are:

- _runId:_ string that identifies the run

<hr>

### files*list(\_commitId, path*)
### files_list(\_commitId, path*)

List the files in a folder in the Domino project. The parameters are:

Expand All @@ -136,7 +136,7 @@ List the files in a folder in the Domino project. The parameters are:

<hr>

### files*upload(\_path, file*)
### files_upload(\_path, file*)

Upload a Python file object into the specified path inside the project. See `examples/upload_file.py` for an example. The parameters, both of which are required, are:

Expand All @@ -145,15 +145,15 @@ Upload a Python file object into the specified path inside the project. See `exa

<hr>

### blobs*get(\_key*)
### blobs_get(\_key*)

Retrieve a file from the Domino server by blob key. The parameters are:

- **key:** The key of the file to fetch from the blob server.

<hr>

### app*publish(\_unpublishRunningApps=True*, _hardwareTierId=None_)
### app_publish(\_unpublishRunningApps=True*, _hardwareTierId=None_)

Publishes an app in the Domino project, or republish an existing app. The parameters are:

Expand All @@ -168,7 +168,7 @@ Stops all running apps in the Domino project.

<hr>

### job*start(\_command*, _commit_id=None_, _hardware_tier_name=None_, _environment_id=None_, _on_demand_spark_cluster_properties=None_):
### job_start(\_command*, _commit_id=None_, _hardware_tier_name=None_, _environment_id=None_, _on_demand_spark_cluster_properties=None_):

Starts a new Job (run) in the project

Expand Down Expand Up @@ -220,7 +220,7 @@ Starts a new Job (run) in the project

<hr>

### job*stop(\_job_id*, _commit_results=True_):
### job_stop(\_job_id*, _commit_results=True_):

Stops the Job (run) in the project

Expand All @@ -229,15 +229,15 @@ Stops the Job (run) in the project

<hr>

### job*status(\_job_id*):
### job_status(\_job_id*):

Gets the status of a Job

- _job_id (string):_ Job identifier

<hr>

### job*start_blocking(\_poll_freq=5*, _max_poll_time=6000_, \*\*kwargs):
### job_start_blocking(\_poll_freq=5*, _max_poll_time=6000_, \*\*kwargs):

Starts a job and polls until the job is finished. Additionally this method supports all the
parameter in `job_start` method
Expand Down
4 changes: 3 additions & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -50,9 +50,11 @@ def get_version():
"black==22.3.0",
"apache-airflow==1.10.15",
"pre-commit==2.19.0",
"nbconvert==6.0.0",
"Jinja2==2.11.3",
],
extras_require={
"airflow": ["apache-airflow==1.*,>=1.10"],
"airflow": ["apache-airflow==2.2.4"],
"data": ["dominodatalab-data>=0.1.0"],
},
)