Hi again everyone 🙂

I’m having a weird exception and I can’t figure out why

I have a simple task who uses my new input plugin, then log it then put it in a output chan

It works a bit but then I get

17-09-06 12:00:16 Maths-MacBook-Pro.local WARN [onyx.peer.task-lifecycle:141] -
                              java.lang.Thread.run              Thread.java:  745
java.util.concurrent.ThreadPoolExecutor$Worker.run  ThreadPoolExecutor.java:  617
 java.util.concurrent.ThreadPoolExecutor.runWorker  ThreadPoolExecutor.java: 1142
                                               ...
                 clojure.core.async/thread-call/fn                async.clj:  442
 onyx.peer.task-lifecycle/start-task-lifecycle!/fn       task_lifecycle.clj:  939
      onyx.peer.task-lifecycle/run-task-lifecycle!       task_lifecycle.clj:  466
                onyx.peer.task-lifecycle/iteration       task_lifecycle.clj:  448
    onyx.peer.task-lifecycle.TaskStateMachine/exec       task_lifecycle.clj:  859
onyx.peer.task-lifecycle/wrap-lifecycle-metrics/fn       task_lifecycle.clj:  886
        onyx.peer.task-lifecycle/build-apply-fn/fn       task_lifecycle.clj:  523
                      onyx.peer.transform/apply-fn            transform.clj:   64
               onyx.peer.transform/apply-fn-single            transform.clj:   18
                                clojure.core/doall                 core.clj: 3128
                                clojure.core/dorun                 core.clj: 3113
                                  clojure.core/seq                 core.clj:  137
                                               ...
                               clojure.core/map/fn                 core.clj: 2733
            onyx.peer.transform/apply-fn-single/fn            transform.clj:   21
         onyx.peer.transform/collect-next-segments            transform.clj:    8
      onyx.peer.transform/collect-next-segments/fn            transform.clj:    8
                           clojure.core/partial/fn                 core.clj: 2604
                           clojure.core/partial/fn                 core.clj: 2605
                           clojure.core/partial/fn                 core.clj: 2606

clojure.lang.ExceptionInfo: Wrong number of args (4) passed to: core/identity

clojure.lang.ExceptionInfo: Handling uncaught exception thrown inside task lifecycle :lifecycle/prepare-batch. Killing the job. -> Exception type: clojure.lang.ExceptionInfo. Exception message: Wrong number of args (4) passed to: core/identity

I have absolutely no idea where this come from ...

Any idea ?

My workflow is like so :

(def workflow
  [[:in :log]
   [:log :out]])

And I cannot figure out where the :lifecycle/prepare-batch exception happen

BTW I’m using clojure 1.9.0-alpha19

(because I use specs)

And onyx from git : “https://github.com/onyx-platform/onyx.git” “7ed0c121139817d1782a03061fcbcd791a711f4e”

Which is basically the lastest commit on 0.10.x branch

@dwarfylenain Hm… Can I see your catalog? I’ll bet you have an :onyx/fn defined to :clojure.core/identity somewhere and its trying to invoke that in your plugin with the 4-args.

Hi

Well I don't

Not using identity at all

I'm not in front of computer so I will send catalog later but basically the only fn I have prints to log and returns the segment

Alrighty. If you can let us have a look at the repo I can help diagnose further.

@michaeldrogalis great thanks I will give you access to GitHub repo ...