FLINK-5725: Add extra Flink details to paasta status

paasta_tools/cli/cmds/status.py

@@ -766,6 +766,7 @@ def append_pod_status(pod_status, output: List[str]):
 def _print_flink_status_from_job_manager(
     service: str,
     instance: str,
+    cluster: str,
     output: List[str],
     flink: Mapping[str, Any],
     client: PaastaOApiClient,
@@ -809,6 +810,17 @@ def _print_flink_status_from_job_manager(
         dashboard_url = metadata["annotations"].get("flink.yelp.com/dashboard_url")
         output.append(f"    URL: {dashboard_url}/")
 
+    # Print Flink config link resources
+    if verbose:
+        output.append(
+            f"    Yelpsoa configs: https://sourcegraph.yelpcorp.com/sysgit/yelpsoa-configs/-/tree/{service}"
+        )
+        cluster_without_pnw_dash = cluster.replace("pnw-", "")
+        output.append(
+            f"    Srv configs: https://sourcegraph.yelpcorp.com/sysgit/srv-configs/-/tree/ecosystem/"
+            f"{cluster_without_pnw_dash}/{service}"
+        )
+
     color = PaastaColors.green if status["state"] == "running" else PaastaColors.yellow
     output.append(f"    State: {color(status['state'].title())}")
 
@@ -988,7 +1000,7 @@ def print_flink_status(
         return 1
 
     return _print_flink_status_from_job_manager(
-        service, instance, output, flink, client, verbose
+        service, instance, cluster, output, flink, client, verbose
     )
 
 
@@ -1015,7 +1027,7 @@ def print_flinkeks_status(
         return 1
 
     return _print_flink_status_from_job_manager(
-        service, instance, output, flink, client, verbose
+        service, instance, cluster, output, flink, client, verbose
     )
 
 

tests/cli/test_cmds_status.py

@@ -2712,6 +2712,8 @@ def test_output_stopping_jobmanager(
         status = mock_flink_status["status"]
         expected_output = [
             f"    Config SHA: 00000",
+            f"    Yelpsoa configs: https://sourcegraph.yelpcorp.com/sysgit/yelpsoa-configs/-/tree/fake_service",
+            f"    Srv configs: https://sourcegraph.yelpcorp.com/sysgit/srv-configs/-/tree/ecosystem/fake_cluster/fake_service",
             f"    State: {PaastaColors.yellow(status['state'].title())}",
             f"    Pods: 3 running, 0 evicted, 0 other",
         ]
@@ -2755,6 +2757,8 @@ def test_output_stopping_taskmanagers(
         status = mock_flink_status["status"]
         expected_output = [
             f"    Config SHA: 00000",
+            f"    Yelpsoa configs: https://sourcegraph.yelpcorp.com/sysgit/yelpsoa-configs/-/tree/fake_service",
+            f"    Srv configs: https://sourcegraph.yelpcorp.com/sysgit/srv-configs/-/tree/ecosystem/fake_cluster/fake_service",
             f"    State: {PaastaColors.yellow(status['state'].title())}",
             f"    Pods: 1 running, 0 evicted, 0 other",
         ]
@@ -2784,7 +2788,7 @@ def test_output_1_verbose(
         mock_naturaltime.return_value = "one day ago"
         output = []
         print_flink_status(
-            cluster="fake_cluster",
+            cluster="pnw-fake_cluster",
             service="fake_service",
             instance="fake_instance",
             output=output,
@@ -2798,6 +2802,8 @@ def test_output_1_verbose(
             datetime.datetime.fromtimestamp(int(job_details_obj.start_time) // 1000)
         )
         expected_output = _get_base_status_verbose_1(metadata) + [
+            f"    Yelpsoa configs: https://sourcegraph.yelpcorp.com/sysgit/yelpsoa-configs/-/tree/fake_service",
+            f"    Srv configs: https://sourcegraph.yelpcorp.com/sysgit/srv-configs/-/tree/ecosystem/fake_cluster/fake_service",
             f"    State: {PaastaColors.green(status['state'].title())}",
             f"    Pods: 3 running, 0 evicted, 0 other",
             f"    Jobs: 1 running, 0 finished, 0 failed, 0 cancelled",