equal
deleted
inserted
replaced
50 with self.session() as session: |
50 with self.session() as session: |
51 j = session.query(Job.id).all() |
51 j = session.query(Job.id).all() |
52 self.assertEqual(j,[(job.dbjob,)]) |
52 self.assertEqual(j,[(job.dbjob,)]) |
53 |
53 |
54 self.assertEqual(exJobs[job.dbjob],job) |
54 self.assertEqual(exJobs[job.dbjob],job) |
|
55 self.assertEqual(self.log.e[0]['message'], ("Job(%s) created."%job.dbjob,)) |
55 |
56 |
56 def testCreate2(self): |
57 def testCreate2(self): |
57 with self.session() as session: |
58 with self.session() as session: |
58 u = User(name='test',apikey='abcdef123456789') |
59 u = User(name='test',apikey='abcdef123456789') |
59 session.add(u) |
60 session.add(u) |
115 |
116 |
116 def testSetError(self): |
117 def testSetError(self): |
117 self.job.setError(Task(Telnumber('123456789'),self),Exception("muhaha")) |
118 self.job.setError(Task(Telnumber('123456789'),self),Exception("muhaha")) |
118 errors = self.flushLoggedErrors(Exception) |
119 errors = self.flushLoggedErrors(Exception) |
119 self.assertEqual(len(errors), 1) |
120 self.assertEqual(len(errors), 1) |
120 self.assertEqual(self.log.e[0]['why'], "Error: Job(%s) to '0049123456789' failed."%self.job.dbjob) |
121 self.assertEqual(self.log.e[1]['message'], ("Job(%s) status changed to: error."%self.job.dbjob,)) |
|
122 self.assertEqual(self.log.e[2]['why'], "Error: Job(%s) to '0049123456789' failed."%self.job.dbjob) |
121 |
123 |
122 with self.session() as session: |
124 with self.session() as session: |
123 u = session.merge(self.user) |
125 u = session.merge(self.user) |
124 job = u.job(self.job.dbjob) |
126 job = u.job(self.job.dbjob) |
125 self.assertEqual(job.status,"error") |
127 self.assertEqual(job.status,"error") |
127 def testSetStatus(self): |
129 def testSetStatus(self): |
128 task = Task(Telnumber('123456789'),self.job) |
130 task = Task(Telnumber('123456789'),self.job) |
129 status = Status(self.provider,"a") |
131 status = Status(self.provider,"a") |
130 self.job.setStatus(task, status) |
132 self.job.setStatus(task, status) |
131 |
133 |
132 self.assertEqual(self.log.e[0]['message'], ("Job(%s) to '0049123456789' ended sucecessfully via bla:a."%self.job.dbjob,)) |
134 self.assertEqual(self.log.e[1]['message'], ("Job(%s) status changed to: sended."%self.job.dbjob,)) |
|
135 self.assertEqual(self.log.e[2]['message'], ("Job(%s) to '0049123456789' ended sucecessfully via bla:a."%self.job.dbjob,)) |
133 |
136 |
134 with self.session() as session: |
137 with self.session() as session: |
135 u = session.merge(self.user) |
138 u = session.merge(self.user) |
136 job = u.job(self.job.dbjob) |
139 job = u.job(self.job.dbjob) |
137 self.assertEqual(job.status,"sended") |
140 self.assertEqual(job.status,"sended") |