def handler()

in backend/lambdas/tasks/submit_query_results.py [0:0]

• 33 lines of code
• 8 McCabe index (conditional complexity)

def handler(event, context):
    query_id = event["QueryId"]
    results = paginate(
        athena, athena.get_query_results, ["ResultSet.Rows"], QueryExecutionId=query_id
    )
    rows = [result for result in results]
    header_row = rows.pop(0)
    path_field_index = next(
        (
            index
            for (index, d) in enumerate(header_row["Data"])
            if d["VarCharValue"] == "$path"
        ),
        None,
    )

    paths = [row["Data"][path_field_index]["VarCharValue"] for row in rows]
    messages = []
    for p in paths:
        msg = {
            "JobId": event["JobId"],
            "Object": p,
            "Columns": event["Columns"],
            "RoleArn": event.get("RoleArn", None),
            "DeleteOldVersions": event.get("DeleteOldVersions", True),
            "IgnoreObjectNotFoundExceptions": event.get(
                "IgnoreObjectNotFoundExceptions", False
            ),
            "Format": event.get("Format"),
            "Manifest": event.get("Manifest"),
        }
        messages.append({k: v for k, v in msg.items() if v is not None})

    batch_sqs_msgs(queue, messages)

    return len(paths)