v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadCypherAction.java [84:102]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private void run(Neo4jConnection connection) {
    TransactionConfig txConfig =
        TransactionConfig.builder()
            .withMetadata(
                Neo4jTelemetry.transactionMetadata(
                    Map.of(
                        "sink", "neo4j",
                        "step", "cypher-preload-action",
                        "execution", executionMode.name().toLowerCase(Locale.ROOT))))
            .build();
    switch (executionMode) {
      case TRANSACTION:
        connection.writeTransaction(tx -> tx.run(cypher).consume(), txConfig);
        break;
      case AUTOCOMMIT:
        connection.runAutocommit(cypher, txConfig);
        break;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/CypherActionFn.java [80:98]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private void run() {
    TransactionConfig txConfig =
        TransactionConfig.builder()
            .withMetadata(
                Neo4jTelemetry.transactionMetadata(
                    Map.of(
                        "sink", "neo4j",
                        "step", "cypher-action",
                        "execution", executionMode.name().toLowerCase(Locale.ROOT))))
            .build();
    switch (executionMode) {
      case TRANSACTION:
        connection.writeTransaction(tx -> tx.run(cypher).consume(), txConfig);
        break;
      case AUTOCOMMIT:
        connection.runAutocommit(cypher, txConfig);
        break;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -