b975316fc6bace78b4e181d5d96ac09e460f791a,grid/pubsub/worker.py,Worker,fit_worker,#Worker#Any#,23

Before Change

                validation_data=(valid_input, valid_target),
                verbose=False,
                epochs=decoded["epochs"],
                callbacks=[pipe]
            )

        else:
            raise NotImplementedError("Only compatible with Keras at the moment")

After Change

                model=model
            )

            monitor_thread = threading.Thread(target = self.listen_to_channel, args = (self.train_meta, train_channel + ":" + self.id))
            monitor_thread.start()

            print("training model")

            model.fit(

Instances