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
44 changes: 43 additions & 1 deletion airflow-ctl-tests/tests/airflowctl_tests/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -241,19 +241,61 @@ def test_commands(login_command, date_param):
# Define test commands to run with actual running API server
return [
login_command,
# Assets commands
"assets list",
# Backfill commands
"backfill list",
# Config commands
"config get --section core --option executor",
"config list",
"config lint",
# Connections commands
"connections create --connection-id=test_con --conn-type=mysql --password=TEST_PASS -o json",
"connections list",
"connections list -o yaml",
"connections list -o tabledags list",
"connections list -o table",
"connections get --conn-id=test_con",
"connections get --conn-id=test_con -o json",
"connections update --connection-id=test_con --conn-type=postgres",
"connections import tests/airflowctl_tests/fixtures/test_connections.json",
"connections delete --conn-id=test_con",
"connections delete --conn-id=test_import_conn",
# DAGs commands
"dags list",
"dags get --dag-id=example_bash_operator",
"dags pause --dag-id=example_bash_operator",
"dags unpause --dag-id=example_bash_operator",
"dags update --dag-id=example_bash_operator --is-paused=false",
# DAG Run commands
f"dagrun trigger --dag-id=example_bash_operator --logical-date={date_param} --run-after={date_param}",
"dagrun list --dag-id example_bash_operator --state success --limit=1",
f"dagrun get --dag-id=example_bash_operator --dagrun-id=manual__{date_param}",
f"dagrun delete --dag-id=example_bash_operator --dagrun-id=manual__{date_param}",
# Jobs commands
"jobs list",
# Pools commands
"pools create --name=test_pool --slots=5",
"pools list",
"pools get --pool-name=test_pool",
"pools get --pool-name=test_pool -o yaml",
"pools update --pool=test_pool --slots=10",
"pools import tests/airflowctl_tests/fixtures/test_pools.json",
"pools export tests/airflowctl_tests/fixtures/pools_export.json --output=json",
"pools delete --pool=test_pool",
"pools delete --pool=test_import_pool",
# Providers commands
"providers list",
# Variables commands
"variables create --key=test_key --value=test_value",
"variables list",
"variables get --variable-key=test_key",
"variables get --variable-key=test_key -o table",
"variables update --key=test_key --value=updated_value",
"variables import tests/airflowctl_tests/fixtures/test_variables.json",
"variables export tests/airflowctl_tests/fixtures/variables_export.json",
"variables delete --variable-key=test_key",
"variables delete --variable-key=test_import_var",
"variables delete --variable-key=test_import_var_with_desc",
# Version command
"version --remote",
]
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
[
{
"deferred_slots": 0,
"description": "Default pool",
"include_deferred": false,
"name": "default_pool",
"occupied_slots": 0,
"open_slots": 128,
"queued_slots": 0,
"running_slots": 0,
"scheduled_slots": 0,
"slots": 128
},
{
"deferred_slots": 0,
"description": null,
"include_deferred": false,
"name": "test_pool",
"occupied_slots": 0,
"open_slots": 10,
"queued_slots": 0,
"running_slots": 0,
"scheduled_slots": 0,
"slots": 10
},
{
"deferred_slots": 0,
"description": "Test pool for import",
"include_deferred": false,
"name": "test_import_pool",
"occupied_slots": 0,
"open_slots": 10,
"queued_slots": 0,
"running_slots": 0,
"scheduled_slots": 0,
"slots": 10
}
]
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
{
"test_import_conn": {
"conn_type": "postgres",
"host": "localhost",
"login": "testuser",
"password": "testpass",
"port": 5432,
"extra": "{}",
"description": "Test connection for import"
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
[
{
"name": "test_import_pool",
"slots": 10,
"description": "Test pool for import",
"include_deferred": false
}
]
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
{
"test_import_var": "import_value",
"test_import_var_with_desc": {
"value": "import_value_with_description",
"description": "Test variable with description"
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
{
"test_import_var": "import_value",
"test_import_var_with_desc": {
"description": "Test variable with description",
"value": "import_value_with_description"
},
"test_key": "updated_value"
}