action.rb in workato-connector-sdk-0.3.0

- old
+ new

@@ -59,9 +59,20 @@
 
           @retries_left -= 1
           sleep(RETRY_DELAY) && retry
         end
 
+        def invoke(input = {})
+          extended_schema = extended_schema(nil, input)
+          config_schema = Schema.new(schema: config_fields_schema)
+          input_schema = Schema.new(schema: extended_schema[:input])
+          output_schema = Schema.new(schema: extended_schema[:output])
+
+          input = apply_input_schema(input, config_schema + input_schema)
+          output = execute(nil, input, input_schema, output_schema)
+          apply_output_schema(output, output_schema)
+        end
+
         def checkpoint!(continue:, temp_output: nil)
           # no-op
         end
 
         def reinvoke_after(seconds:, continue:, temp_output: nil)