def process_blob()

in pipeline/function_app.py [0:0]

• 17 lines of code
• 2 McCabe index (conditional complexity)

def process_blob(context):
  blob = context.get_input()
  logging.info(f"Process Blob sub Orchestration - Processing blob: {blob}")
  # Waits for the result of an activity function that retrieves the blob content
  text_result = yield context.call_activity("runDocIntel", blob)
  json_str = yield context.call_activity("callAoai", text_result)
  task_result = yield context.call_activity(
      "writeToBlob", 
      {
          "json_str": json_str, 
          "blob_name": blob["name"]
      }
  )
  return {
      "blob": blob,
      "text_result": text_result,
      "task_result": task_result
  }