Skip to content

Commit

Permalink
debug
Browse files Browse the repository at this point in the history
  • Loading branch information
AnkitCLI committed Oct 28, 2024
1 parent 7569f33 commit 6e8f093
Show file tree
Hide file tree
Showing 57 changed files with 643 additions and 79 deletions.
21 changes: 13 additions & 8 deletions .github/workflows/e2e.yml
Original file line number Diff line number Diff line change
Expand Up @@ -74,15 +74,20 @@ jobs:
- name: Run all e2e tests
if: github.event_name == 'workflow_dispatch' || github.event_name == 'push' || steps.filter.outputs.e2e-test == 'true'
run: python3 e2e/src/main/scripts/run_e2e_test.py --testRunner **/${{ matrix.tests }}/**/TestRunner.java
# Step to check if there were failures and run retry runner if needed
- name: Check for Failed Tests and Run Retry Runner
# Step to check if there were failures and list contents of target directory for debugging
- name: List target directory contents for debugging
run: ls -al ./plugin/target
# Step to check if there were failures and run retry runner if needed
- name: Check for Failed Tests and Run Retry Test Runner
if: always() # Always run this step to check for failures
run: if [ -f ./plugin/target/failed_scenarios.txt ]; then
echo "Found failed scenarios. Running retry tests."
python3 e2e/src/main/scripts/run_e2e_test.py --testRunner **/${{ matrix.tests }}/**/RetryTestRunner.java
else
echo "No failed scenarios found."
fi
run: |
echo "Checking for failed_scenarios.txt"
if [ -f ./plugin/target/failed_scenarios.txt ]; then
echo "Found failed scenarios. Running retry tests."
python3 e2e/src/main/scripts/run_e2e_test.py --testRunner **/${{ matrix.tests }}/**/RetryTestRunner.java
else
echo "No failed scenarios found."
fi
- name: Upload debug files
uses: actions/upload-artifact@v3
if: always()
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/bigquery/sink/GCSToBigQuery.feature
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ Feature: BigQuery sink - Verification of GCS to BigQuery successful data transfe
Then Enter BigQuery property reference name
Then Enter BigQuery property projectId "projectId"
Then Enter BigQuery property datasetProjectId "projectId"
Then Override Service account details if set in environment variables
Then Override Service account details if set in environment variablesss
Then Enter BigQuery property dataset "dataset"
Then Enter BigQuery sink property table name
Then Toggle BigQuery sink property truncateTable to true
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ Feature: BigQuery sink - Verification of GCS to BigQuery successful data transfe
Given Open Datafusion Project to configure pipeline
When Source is GCS
When Sink is BigQuery
Then Open GCS source properties
Then Open GCS source propertiess
Then Enter GCS property reference name
Then Enter GCS property "projectId" as macro argument "gcsProjectId"
Then Enter GCS property "serviceAccountType" as macro argument "serviceAccountType"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ Feature: BigQuery source - Validate BigQuery source plugin error scenarios

Scenario Outline:Verify BigQuery Source properties validation errors for mandatory fields
Given Open Datafusion Project to configure pipeline
When Source is BigQuery
When Source is BigQuerys
Then Open BigQuery source properties
Then Enter the BigQuery properties with blank property "<property>"
Then Validate mandatory property error for "<property>"
Expand All @@ -29,7 +29,7 @@ Feature: BigQuery source - Validate BigQuery source plugin error scenarios

Scenario Outline:Verify BigQuery Source properties validation errors for incorrect format of projectIds
Given Open Datafusion Project to configure pipeline
When Source is BigQuery
When Source is BigQuerys
Then Open BigQuery source properties
Then Enter BigQuery property reference name
Then Enter BigQuery property projectId "<ProjectID>"
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/bigqueryexecute/BQExecute.feature
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@BQExecute
@BQExecutes
Feature: BigQueryExecute - Verify data transfer using BigQuery Execute plugin

@BQ_SOURCE_TEST @BQ_SINK_TEST @BQ_EXECUTE_SQL @BQExecute_Required
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@BQExecute
@BQExecutes
Feature: BigQueryExecute - Verify BigQueryExecute plugin error scenarios

Scenario: Verify BigQueryExecute validation error for mandatory field SQL Query
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@BQExecute
@BQExecutes
Feature: BigQueryExecute - Verify data transfer using BigQuery Execute plugin with macro arguments

@BQ_SOURCE_TEST @BQ_SINK_TEST @BQ_EXECUTE_SQL
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/bigtable/BigTableToBigTable.feature
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations under
# the License.
@BigTable @BIGTABLE_SOURCE_TEST
@BigTables @BIGTABLE_SOURCE_TEST
Feature: BigTable source - Verification of BigTable to BigTable Successful Data Transfer

@BIGTABLE_SINK_TEST @bigtable_Required
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/datastore/runtime.feature
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
# License for the specific language governing permissions and limitations under
# the License.

@DataStore
@DataStores
Feature: DataStore - Verification of Datastore to Datastore Successful Data Transfer

@DATASTORE_SOURCE_ENTITY @datastore_Required
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/gcs/sink/GCSSink.feature
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Sink
@GCS_Sinks
Feature: GCS sink - Verification of GCS Sink plugin

@CMEK @GCS_SINK_TEST @BQ_SOURCE_TEST
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/gcs/sink/GCSSinkError.feature
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Sink
@GCS_Sinks
Feature: GCS sink - Verify GCS Sink plugin error scenarios

Scenario Outline:Verify GCS Sink properties validation errors for mandatory fields
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/gcs/source/GCSSourceError.feature
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Source
@GCS_Sources
Feature: GCS source - Verify GCS Source plugin error scenarios

Scenario Outline:Verify GCS Source properties validation errors for mandatory fields
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Source
@GCS_Sources
Feature: GCS source - Verification of GCS to BQ successful data transfer

@GCS_CSV_TEST @BQ_SINK_TEST
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Source
@GCS_Sources
Feature: GCS source - Verification of GCS to BQ successful data transfer

@BQ_SINK_TEST @GCS_READ_RECURSIVE_TEST
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Source
@GCS_Sources
Feature: GCS source - Verification of GCS to GCS Additional Tests successful

@GCS_AVRO_FILE @GCS_SINK_TEST @GCS_Source_Required @ITN_TEST
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Source
@GCS_Sources
Feature: GCS source - Verification of GCS to GCS successful data transfer using connections

@GCS_CSV_TEST @GCS_SINK_TEST @GCS_CONNECTION
Expand Down
12 changes: 6 additions & 6 deletions src/e2e-test/features/gcs/source/GCSourceSchema.feature
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@GCS_Source
@GCS_Sources
Feature: GCS source - Validate GCS plugin output schema for different formats

Scenario Outline:GCS Source output schema validation for csv and tsv format
Expand All @@ -7,7 +7,7 @@ Feature: GCS source - Validate GCS plugin output schema for different formats
Then Open GCS source properties
Then Enter GCS property projectId and reference name
Then Override Service account details if set in environment variables
Then Enter GCS source property path "<GcsPath>"
Then Enter GCS source property path "<GcsPath>"s
Then Select GCS property format "<FileFormat>"
Then Toggle GCS source property skip header to true
Then Validate output schema with expectedSchema "<ExpectedSchema>"
Expand All @@ -28,7 +28,7 @@ Feature: GCS source - Validate GCS plugin output schema for different formats
Then Enter GCS property projectId and reference name
Then Override Service account details if set in environment variables
Then Enter GCS source property path "<GcsPath>"
Then Select GCS property format "<FileFormat>"
Then Select GCS property format "<FileFormat>"s
Then Validate output schema with expectedSchema "<ExpectedSchema>"
@GCS_BLOB_TEST
Examples:
Expand All @@ -52,7 +52,7 @@ Feature: GCS source - Validate GCS plugin output schema for different formats
Given Open Datafusion Project to configure pipeline
When Source is GCS
Then Open GCS source properties
Then Enter GCS property projectId and reference name
Then Enter GCS property projectId and reference names
Then Override Service account details if set in environment variables
Then Enter GCS source property path "<GcsPath>"
Then Select GCS property format "<FileFormat>"
Expand All @@ -70,7 +70,7 @@ Feature: GCS source - Validate GCS plugin output schema for different formats
Given Open Datafusion Project to configure pipeline
When Source is GCS
Then Open GCS source properties
Then Enter GCS property projectId and reference name
Then Enter GCS property projectId and reference names
Then Override Service account details if set in environment variables
Then Enter GCS source property path "gcsDelimitedFile"
Then Select GCS property format "delimited"
Expand All @@ -82,7 +82,7 @@ Feature: GCS source - Validate GCS plugin output schema for different formats
Given Open Datafusion Project to configure pipeline
When Source is GCS
Then Open GCS source properties
Then Enter GCS property projectId and reference name
Then Enter GCS property projectId and reference names
Then Enter GCS source property path "<GcsPath>"
Then Select GCS property format "<FileFormat>"
Then Toggle GCS source property skip header to true
Expand Down
4 changes: 2 additions & 2 deletions src/e2e-test/features/gcscopy/GCSCopy.feature
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
# License for the specific language governing permissions and limitations under
# the License.

@GCSCopy
@GCSCopys
Feature:GCSCopy - Verification of successful objects copy from one bucket to another

@CMEK @GCS_CSV_TEST @GCS_SINK_TEST @GCSCopy_Required @ITN_TEST
Expand All @@ -22,7 +22,7 @@ Feature:GCSCopy - Verification of successful objects copy from one bucket to ano
When Select plugin: "GCS Copy" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Copy"
And Replace input plugin property: "project" with value: "projectId"
And Enter GCSCopy property source path "gcsCsvFile"
And Enter GCSCopy property source path "gcsCsvFile"s
And Enter GCSCopy property destination path
Then Override Service account details if set in environment variables
Then Enter GCSCopy property encryption key name "cmekGCS" if cmek is enabled
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ Feature: GCSCopy - Validate GCSCopy plugin error scenarios
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Copy" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Copy"
Then Click on the Validate button
Then Click on the Validate buttons
Then Verify mandatory property error for below listed properties:
| sourcePath |
| destPath |
Expand Down
2 changes: 1 addition & 1 deletion src/e2e-test/features/gcscopy/GCSCopy_WithMacro.feature
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ Feature:GCSCopy - Verification of successful objects copy from one bucket to ano

@CMEK @GCS_CSV_TEST @GCS_SINK_TEST @GCSCopy_Required @ITN_TEST
Scenario:Validate successful copy object from one bucket to another new bucket with macro arguments
Given Open Datafusion Project to configure pipeline
Given Open Datafusion Project to configure pipelines
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Copy" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Copy"
Expand Down
6 changes: 3 additions & 3 deletions src/e2e-test/features/gcscreate/GCSCreate.feature
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ Feature: GCSCreate - Verification of GCS Create plugin
Then Enter GCSCreate property encryption key name "cmekGCS" if cmek is enabled
Then Validate "GCS Create" plugin properties
Then Close the GCS Create properties
Then Save and Deploy Pipeline
Then Save and Deploy Pipelines
Then Run the Pipeline in Runtime
Then Wait till pipeline is in running state
Then Open and capture logs
Expand All @@ -34,7 +34,7 @@ Feature: GCSCreate - Verification of GCS Create plugin
Then Select GCS Create property fail if objects exists as "true"
Then Override Service account details if set in environment variables
Then Validate "GCS Create" plugin properties
Then Close the GCS Create properties
Then Close the GCS Create propertiess
Then Save and Deploy Pipeline
Then Run the Pipeline in Runtime
Then Wait till pipeline is in running state
Expand All @@ -55,7 +55,7 @@ Feature: GCSCreate - Verification of GCS Create plugin
Then Override Service account details if set in environment variables
Then Validate "GCS Create" plugin properties
Then Close the GCS Create properties
Then Save and Deploy Pipeline
Then Save and Deploy Pipelines
Then Run the Pipeline in Runtime
Then Wait till pipeline is in running state
Then Verify the pipeline status is "Succeeded"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ Feature: GCSCreate - Verification of GCS Create plugin with macro arguments
Then Validate "GCS Create" plugin properties
Then Close the GCS Create properties
Then Save and Deploy Pipeline
Then Run the Pipeline in Runtime
Then Run the Pipeline in Runtimes
Then Enter runtime argument value "projectId" for key "gcsCreateProjectId"
Then Enter runtime argument value "gcsCreateObject1" for GCSCreate property key "gcsCreateObjectsToCreate"
Then Enter runtime argument value "true" for GCSCreate property key "gcsCreateFailIfObjectExists"
Expand Down
22 changes: 11 additions & 11 deletions src/e2e-test/features/gcsdelete/GCSDelete.feature
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
Then Validate "GCS Delete" plugin properties
Then Close the GCS Delete properties
Then Save and Deploy Pipeline
Then Run the Pipeline in Runtime
Then Run the Pipeline in Runtimes
Then Wait till pipeline is in running state
Then Open and capture logs
Then Verify the pipeline status is "Succeeded"
Expand All @@ -26,7 +26,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property objects to delete as path "gcsCsvFile"
Then Enter the GCS Delete property objects to delete ass path "gcsCsvFile"
Then Override Service account details if set in environment variables
Then Validate "GCS Delete" plugin properties
Then Close the GCS Delete properties
Expand All @@ -45,7 +45,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
When Navigate to the properties page of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property objects to delete as list of objects "gcsDeleteObjectsList"
Then Override Service account details if set in environment variables
Then Override Service account details isf set in environment variables
Then Validate "GCS Delete" plugin properties
Then Close the GCS Delete properties
Then Save and Deploy Pipeline
Expand All @@ -61,7 +61,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property projectId s"projectId"
Then Enter the GCS Delete property objects to delete as path "gcsWildcardPath1"
Then Override Service account details if set in environment variables
Then Validate "GCS Delete" plugin properties
Expand All @@ -81,7 +81,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property objects to delete as path "gcsWildcardPath2"
Then Enter the GCS Delete property objectss to delete as path "gcsWildcardPath2"
Then Override Service account details if set in environment variables
Then Validate "GCS Delete" plugin properties
Then Close the GCS Delete properties
Expand All @@ -98,7 +98,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
When Navigate to the properties pagse of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property objects to delete as path "gcsWildcardPath3"
Then Override Service account details if set in environment variables
Expand All @@ -116,7 +116,7 @@ Feature: GCS Delete - Verification of GCS Delete plugin
Scenario: Verify the GCS Delete successfully deletes file from multiple buckets
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Select plugin: "GCS Delete" from sthe plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property objects from multiple Buckets to delete as list of objects "gcsMultiBucketsPath1"
Expand All @@ -133,10 +133,10 @@ Feature: GCS Delete - Verification of GCS Delete plugin

@GCS_DELETE_MULTIPLE_BUCKETS_TEST
Scenario: Verify the GCS Delete successfully deletes file from multiple buckets use wildcard
Given Open Datafusion Project to configure pipeline
Given Open Datafusion Project to consfigure pipeline
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
When Navigate to the propertises page of plugin: "GCS Delete"
Then Enter the GCS Delete property projectId "projectId"
Then Enter the GCS Delete property objects from multiple Buckets to delete as list of objects "gcsWildcardMultiBucketsPath1"
Then Override Service account details if set in environment variables
Expand All @@ -154,14 +154,14 @@ Feature: GCS Delete - Verification of GCS Delete plugin
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
When Navigate to the properties pagse of plugin: "GCS Delete"
Then Validate mandatory property error for "paths"

Scenario:Verify GCS Delete properties validation error for incorrect bucket path
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Conditions and Actions"
When Select plugin: "GCS Delete" from the plugins list as: "Conditions and Actions"
When Navigate to the properties page of plugin: "GCS Delete"
Then Enter the GCS Delete property objects to delete as path "gcsInvalidBucketName"
Then Enter the GCS Delete property objectss to delete as path "gcsInvalidBucketName"
Then Override Service account details if set in environment variables
Then Verify invalid bucket name error message is displayed for GCS Delete objects to delete path "gcsInvalidBucketName"
Loading

0 comments on commit 6e8f093

Please sign in to comment.