Emit structured log events to ApplicationInsights

cluster/dev-values.yaml

@@ -86,6 +86,9 @@ pctasks:
     keyvault:
       enabled: false
 
+    applicationinsights:
+      enabled: false
+
 pcdev:
   services:
     pctasks:

deployment/helm/deploy-values.template.yaml

@@ -90,6 +90,10 @@ pctasks:
       enabled: true
       url: "{{ tf.keyvault_url }}"
 
+    applicationinsights:
+      enabled: true
+      connection_string: "{{ tf.applicationinsights_connection_string }}"
+
 pcingress:
   services:
     pctasks:

deployment/helm/published/pctasks-server/templates/deployment.yaml

@@ -199,6 +199,11 @@ spec:
               value: "{{ .Values.pctasks.run.keyvault.url }}"
             {{- end }}
 
+            {{- if .Values.pctasks.run.applicationinsights.enabled }}
+            - name: PCTASKS_RUN__APPLICATIONINSIGHTS_CONNECTION_STRING
+              value: "{{ .Values.pctasks.run.applicationinsights.connection_string }}"
+            {{- end }}
+
           livenessProbe:
             httpGet:
               path: "/_mgmt/ping"

deployment/helm/published/pctasks-server/values.yaml

@@ -174,3 +174,7 @@ pctasks:
       sp_tenant_id: ""
       sp_client_id: ""
       sp_client_secret: ""
+
+    applicationinsights:
+      enabled: false
+      connection_string: ""

deployment/terraform/resources/output.tf

@@ -160,6 +160,10 @@ output "instrumentation_key" {
   value = azurerm_application_insights.pctasks.instrumentation_key
 }
 
+output "applicationinsights_connection_string" {
+  value = azurerm_application_insights.pctasks.connection_string
+}
+
 ## PCTasks Server
 
 output "argo_wf_node_group_name" {

docs/getting_started/telemetry.md

@@ -0,0 +1,35 @@
+# Telemetry
+
+## Structured Logs
+
+The pctasks executor generates logs for the following events:
+
+1. `WorkflowCreated`
+2. `WorkflowFinished`
+3. `JobCreated`
+4. `JobFinished` 
+5. `JobPartitionCreated`
+6. `JobPartitionFinished`
+7. `TaskCreated`
+8. `TaskFinished`
+
+In general, a record is emitted when something is created or finished, at the Workflow, Job, JobPartition, and Task levels.
+
+Depending on the level (Workflow, Job, JobPartition, Task) the logs will contain the following fields:
+
+|    Field    |      Record Levels      |                              Description                              |
+| ----------- | ----------------------- | --------------------------------------------------------------------- |
+| type        | All                     | The event type, from the list above                                   |
+| workflowId  | All                     | The ID of the workflow, from the workflow definition                  |
+| datasetId   | All                     | The ID of the dataset, from the workflow definition                   |
+| runId       | All                     | The of the workflow run, generated by pctasks                         |
+| recordLevel | All                     | The level (Workflow, Job, JobPartition, Task) this record belongs to. |
+| jobId       | Job, JobPartition, Task | The ID of the job, from the workflow definition                       |
+| partitionId | JobPartition, Task      | The ID of the partition, from the workflow definition and pctasks     |
+| taskId      | Task                    | The ID of the task, from the workflow definition and pctasks          |
+
+Depending on the record, additional fields will be included:
+
+* `status`: Present for "Finished" events, indicating success or failure of that operation.
+* `errors`: Present for `JobFinished` and `TaskFinished` events when
+  `status="failed"`, containing a list of errors.

pctasks/run/pctasks/run/argo/client.py

@@ -197,6 +197,14 @@ def submit_workflow(
         else:
             kwargs = {}
 
+        if run_settings.applicationinsights_connection_string:
+            env.append(
+                EnvVar(
+                    name="APPLICATIONINSIGHTS_CONNECTION_STRING",
+                    value=run_settings.applicationinsights_connection_string,
+                )
+            )
+
         # Enable local secrets for development environment
         if run_settings.local_secrets:
             for env_var in [
@@ -317,6 +325,14 @@ def submit_task(
         else:
             kwargs = {}
 
+        if run_settings.applicationinsights_connection_string:
+            env.append(
+                EnvVar(
+                    name="APPLICATIONINSIGHTS_CONNECTION_STRING",
+                    value=run_settings.applicationinsights_connection_string,
+                )
+            )
+
         templates = [
             IoArgoprojWorkflowV1alpha1Template(
                 name="run-workflow",

pctasks/run/pctasks/run/settings.py

@@ -121,6 +121,8 @@ def section_name(cls) -> str:
     # Type of workflow runner to use.
     workflow_runner_type: WorkflowRunnerType = WorkflowRunnerType.ARGO
 
+    applicationinsights_connection_string: Optional[str] = None
+
     @property
     def batch_settings(self) -> BatchSettings:
         if not (self.batch_url and self.batch_key and self.batch_default_pool_id):