Skip to content
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
39 changes: 16 additions & 23 deletions .github/workflows/ci.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -40,17 +40,17 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: apache/skywalking-eyes/header@main
dead-link:
runs-on: ubuntu-latest
needs: license
timeout-minutes: 30
steps:
- uses: actions/checkout@v3
- run: sudo npm install -g markdown-link-check@3.10.0
- run: |
for file in $(find . -name "*.md"); do
markdown-link-check -c .dlc.json -q "$file"
done
# dead-link:
# runs-on: ubuntu-latest
# needs: license
# timeout-minutes: 30
# steps:
# - uses: actions/checkout@v3
# - run: sudo npm install -g markdown-link-check@3.10.0
# - run: |
# for file in $(find . -name "*.md"); do
# markdown-link-check -c .dlc.json -q "$file"
# done
lint:
timeout-minutes: 15
runs-on: ubuntu-latest
Expand All @@ -76,7 +76,7 @@ jobs:
matrix:
# YAML parse `3.10` to `3.1`, so we have to add quotes for `'3.10'`, see also:
# https://github.com/actions/setup-python/issues/160#issuecomment-724485470
python-version: ['3.9', '3.10', '3.11', '3.12', '3.13']
python-version: ['3.10', '3.11', '3.12', '3.13']
os: [ubuntu-latest, macOS-latest, windows-latest]
exclude:
# Skip because dependence [py4j](https://pypi.org/project/py4j/) not work on those environments
Expand All @@ -86,13 +86,6 @@ jobs:
python-version: '3.11'
- os: windows-latest
python-version: '3.12'
# Python 3.9 is on macos-13 but not macos-latest (macos-14-arm64)
# https://github.com/actions/setup-python/issues/696#issuecomment-1637587760
- os: macos-latest
python-version: '3.9'
include:
- python-version: '3.9'
os: macos-13
steps:
- uses: actions/checkout@v3
- name: Set up Python ${{ matrix.python-version }}
Expand Down Expand Up @@ -133,7 +126,7 @@ jobs:
- name: Set up Python
uses: actions/setup-python@v4
with:
python-version: 3.11
python-version: '3.10'
- name: Install Dependences
run: |
python -m pip install --upgrade ${{ env.DEPENDENCES }}
Expand Down Expand Up @@ -216,15 +209,15 @@ jobs:
name: CI
if: always()
needs:
- dead-link
# - dead-link
- local-ci
- integrate-test
runs-on: ubuntu-latest
steps:
- name: Status
# if [[ ${{ needs.dead-link.result }} != 'success' ]] || \
run: |
if [[ ${{ needs.dead-link.result }} != 'success' ]] || \
[[ ${{ needs.local-ci.result }} != 'success' ]] || \
if [[ ${{ needs.local-ci.result }} != 'success' ]] || \
([[ ${{ needs.integrate-test.result }} != 'skipped' ]] && [[ ${{ needs.integrate-test.result }} != 'success' ]]); then
echo "CI Failed!"
exit -1
Expand Down
1 change: 1 addition & 0 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""The script for setting up pydolphinscheduler."""

from __future__ import annotations

import logging
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/configuration.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Configuration module for pydolphinscheduler."""

import logging
import os
from pathlib import Path
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/examples/task_dependent_example.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@

task_dependent(this task dependent on task_dependent_external.task_1 and task_dependent_external.task_2).
"""

from pydolphinscheduler import configuration
from pydolphinscheduler.core.workflow import Workflow
from pydolphinscheduler.tasks.dependent import And, Dependent, DependentItem, Or
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/examples/task_sagemaker_example.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

# [start workflow_declare]
"""A example workflow for task sagemaker."""

import json

from pydolphinscheduler.core.workflow import Workflow
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/examples/task_sql_example.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
# [start workflow_declare]

"""A example workflow for task SQL."""

from pathlib import Path

from pydolphinscheduler.core.workflow import Workflow
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
from pydolphinscheduler.tasks.sub_workflow import SubWorkflow
from pydolphinscheduler.tasks.shell import Shell


# [start workflow_declare]
# [start sub_workflow_declare]
with Workflow(name="sub_workflow_downstream") as wf_downstream, Workflow(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

it will instantiate and run all the task it have.
"""

import os
from pathlib import Path

Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/java_gateway.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Module java gateway, contain gateway behavior."""

from __future__ import annotations

import contextlib
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/models/datasource.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Module database."""

from __future__ import annotations

import json
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/models/meta.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
server to get some resource from database, but you want to make sure the return object is a in Python
object.
"""

from __future__ import annotations

from functools import wraps
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/resources_plugin/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Init resources_plugin package."""

from pydolphinscheduler.resources_plugin.github import GitHub
from pydolphinscheduler.resources_plugin.gitlab import GitLab
from pydolphinscheduler.resources_plugin.local import Local
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/resources_plugin/github.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""DolphinScheduler github resource plugin."""

from __future__ import annotations

import base64
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/resources_plugin/gitlab.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""DolphinScheduler gitlab resource plugin."""

from __future__ import annotations

from urllib.parse import urljoin, urlparse
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/resources_plugin/oss.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""DolphinScheduler oss resource plugin."""

from __future__ import annotations

from urllib.parse import urljoin, urlparse
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/dependent.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task dependent."""

from __future__ import annotations

import warnings
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/dvc.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task dvc."""

from __future__ import annotations

from copy import deepcopy
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/kubernetes.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task Kubernetes."""

from pydolphinscheduler.constants import TaskType
from pydolphinscheduler.core.task import BatchTask

Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/mlflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task mlflow."""

from __future__ import annotations

from copy import deepcopy
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/pytorch.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task Pytorch."""

from __future__ import annotations

from pydolphinscheduler.constants import TaskType
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/sql.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task sql."""

from __future__ import annotations

import logging
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/tasks/switch.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Task Switch."""

from __future__ import annotations

from pydolphinscheduler.constants import TaskType
Expand Down
1 change: 1 addition & 0 deletions src/pydolphinscheduler/utils/yaml_parser.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""YAML parser utils, parser yaml string to ``ruamel.yaml`` object and nested key dict."""

from __future__ import annotations

import copy
Expand Down
1 change: 0 additions & 1 deletion tests/core/test_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

"""Test Task Engine."""


from unittest.mock import patch

import pytest
Expand Down
1 change: 0 additions & 1 deletion tests/core/test_local_parameter.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

"""Test parameter."""


import pytest

from pydolphinscheduler.core.parameter import (
Expand Down
1 change: 1 addition & 0 deletions tests/core/test_resource_definition.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test resource definition."""

import pytest

from pydolphinscheduler.core.resource import Resource
Expand Down
1 change: 1 addition & 0 deletions tests/core/test_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test Task class function."""

from __future__ import annotations

import logging
Expand Down
1 change: 1 addition & 0 deletions tests/core/test_workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test workflow."""

from __future__ import annotations

import warnings
Expand Down
1 change: 1 addition & 0 deletions tests/integration/test_java_gateway.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test pydolphinscheduler java gateway."""

import importlib
import warnings
from unittest.mock import PropertyMock, patch
Expand Down
1 change: 1 addition & 0 deletions tests/integration/test_process_definition.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test workflow in integration."""

from __future__ import annotations

import pytest
Expand Down
1 change: 1 addition & 0 deletions tests/integration/test_project.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test pydolphinscheduler project."""

import pytest

from pydolphinscheduler.models import Project, User
Expand Down
1 change: 1 addition & 0 deletions tests/integration/test_tenant.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test pydolphinscheduler tenant."""

import pytest

from pydolphinscheduler.models import Tenant, User
Expand Down
1 change: 1 addition & 0 deletions tests/models/test_database.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test Database."""

import json
from unittest.mock import patch

Expand Down
1 change: 1 addition & 0 deletions tests/resources_plugin/test_github.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test github resource plugin."""

from unittest.mock import PropertyMock, patch

import pytest
Expand Down
1 change: 1 addition & 0 deletions tests/resources_plugin/test_gitlab.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test github resource plugin."""

import pytest

from pydolphinscheduler.resources_plugin.gitlab import GitLab
Expand Down
1 change: 1 addition & 0 deletions tests/resources_plugin/test_local.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test local resource plugin."""

from pathlib import Path
from unittest.mock import PropertyMock, patch

Expand Down
1 change: 1 addition & 0 deletions tests/resources_plugin/test_oss.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test oss resource plugin."""

import pytest

from pydolphinscheduler.resources_plugin.oss import OSS
Expand Down
1 change: 1 addition & 0 deletions tests/resources_plugin/test_s3.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test oss resource plugin."""

import pytest

from pydolphinscheduler.resources_plugin import S3
Expand Down
1 change: 1 addition & 0 deletions tests/tasks/test_condition.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test Task dependent."""

from __future__ import annotations

from unittest.mock import patch
Expand Down
1 change: 1 addition & 0 deletions tests/tasks/test_datax.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test Task DataX."""

from pathlib import Path
from unittest.mock import patch

Expand Down
1 change: 1 addition & 0 deletions tests/tasks/test_dependent.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

"""Test Task dependent."""

from __future__ import annotations

import itertools
Expand Down
Loading
Loading