Skip to content

Commit

Permalink
fixup! feat: add synapse support
Browse files Browse the repository at this point in the history
  • Loading branch information
jayachithra committed Aug 27, 2024
1 parent 060be53 commit bd5bf0f
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 19 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,13 +4,10 @@
from data_factory_testing_framework.state import RunParameter, RunParameterType


@pytest.mark.parametrize("framework_type", [TestFrameworkType.DataFactory, TestFrameworkType.Synapse])
def test_execute_pipeline_activity_child_activities_executed(
framework_type: str, request: pytest.FixtureRequest
) -> None:
def test_execute_pipeline_activity_child_activities_executed(request: pytest.FixtureRequest) -> None:
# Arrange
test_framework = TestFramework(
framework_type=framework_type,
framework_type=TestFrameworkType.DataFactory,
root_folder_path=request.fspath.dirname,
should_evaluate_child_pipelines=True,
)
Expand All @@ -36,14 +33,12 @@ def test_execute_pipeline_activity_child_activities_executed(
next(activities)


@pytest.mark.parametrize("framework_type", [TestFrameworkType.DataFactory, TestFrameworkType.Synapse])
def test_execute_pipeline_activity_evaluate_child_pipelines_child_pipeline_not_known_exception_thrown(
framework_type: str,
request: pytest.FixtureRequest,
) -> None:
# Arrange
test_framework = TestFramework(
framework_type=framework_type,
framework_type=TestFrameworkType.DataFactory,
root_folder_path=request.fspath.dirname,
should_evaluate_child_pipelines=True,
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,17 +3,14 @@
from data_factory_testing_framework.state import RunParameter, RunParameterType


@pytest.mark.parametrize("framework_type", [TestFrameworkType.DataFactory, TestFrameworkType.Synapse])
@pytest.mark.parametrize(
"on_value,expected_outcome",
[("case_1", "case_1_hit"), ("case_2", "case_2_hit")],
)
def test_switch_activity(
framework_type: str, on_value: str, expected_outcome: str, request: pytest.FixtureRequest
) -> None:
def test_switch_activity(on_value: str, expected_outcome: str, request: pytest.FixtureRequest) -> None:
# Arrange
test_framework = TestFramework(
framework_type=framework_type,
framework_type=TestFrameworkType.DataFactory,
root_folder_path=request.fspath.dirname,
should_evaluate_child_pipelines=True,
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,11 @@
from data_factory_testing_framework import TestFramework, TestFrameworkType


@pytest.mark.parametrize("framework_type", [TestFrameworkType.DataFactory, TestFrameworkType.Synapse])
def test_string_default_variables(framework_type: str, request: pytest.FixtureRequest) -> None:
def test_string_default_variables(request: pytest.FixtureRequest) -> None:
# Arrange
test_framework = TestFramework(framework_type=framework_type, root_folder_path=request.fspath.dirname)
test_framework = TestFramework(
framework_type=TestFrameworkType.DataFactory, root_folder_path=request.fspath.dirname
)
pipeline = test_framework.get_pipeline_by_name("default_variables")

# Act
Expand Down
7 changes: 4 additions & 3 deletions tests/functional/xml/test_xml.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,11 @@
from data_factory_testing_framework import TestFramework, TestFrameworkType


@pytest.mark.parametrize("framework_type", [TestFrameworkType.DataFactory, TestFrameworkType.Synapse])
def test_batch_job_pipeline(framework_type: str, request: pytest.FixtureRequest) -> None:
def test_batch_job_pipeline(request: pytest.FixtureRequest) -> None:
# Arrange
test_framework = TestFramework(framework_type=framework_type, root_folder_path=request.fspath.dirname)
test_framework = TestFramework(
framework_type=TestFrameworkType.DataFactory, root_folder_path=request.fspath.dirname
)
pipeline = test_framework.get_pipeline_by_name("xpath_example_08_a")

# Act
Expand Down

0 comments on commit bd5bf0f

Please sign in to comment.