input_reading = msg.lookup_signal(signal_in).value

        input_reading = 19

        pid_out = pid.Update(input_reading)

        if pid_out > 0:

            self.canbus.set_output(module_out, signal_out, 1)

            run_time = datetime.datetime.now() + datetime.timedelta(milliseconds=pid_out)

            self.apscheduler.add_job(self.canbus.set_output, "date", run_date=run_time, args=[module_out, signal_out, 0])

def func():

    print(1)

def main():

    database = Database()

    canbus = CanBus(database)

    canbus.start()

    canbus.start_receive()

    scheduler = Scheduler(canbus)

    scheduler.start()

    while True:

        time.sleep(0.001)

if __name__ == "__main__":

    main()