From 7c72a336b53657e85672604d2af74a10d1d1930d Mon Sep 17 00:00:00 2001 From: Saransh Date: Wed, 13 Jul 2022 15:54:53 +0530 Subject: [PATCH 1/2] Process --- calc.py | 17 ------------ calc_process.py | 16 ++++++++++++ test_calc.py | 33 ----------------------- test_calc_process.py | 62 ++++++++++++++++++++++++++++++++++++++++++++ 4 files changed, 78 insertions(+), 50 deletions(-) delete mode 100644 calc.py create mode 100644 calc_process.py delete mode 100644 test_calc.py create mode 100644 test_calc_process.py diff --git a/calc.py b/calc.py deleted file mode 100644 index 74b6f47..0000000 --- a/calc.py +++ /dev/null @@ -1,17 +0,0 @@ -def add(a, b): - return a + b - - -def subtract(a, b): - return a - b - - -def divide(a, b): - if b == 0: - raise ValueError("Cannot divide by zero") - else: - return a / b - - -def multiply(a, b): - return a * b diff --git a/calc_process.py b/calc_process.py new file mode 100644 index 0000000..ae0289b --- /dev/null +++ b/calc_process.py @@ -0,0 +1,16 @@ +def add(queue, a, b): + queue.put(a + b) + + +def subtract(queue, a, b): + queue.put(a - b) + + +def divide(queue, a, b): + if b == 0: + raise ValueError("Cannot divide by zero") + queue.put(a / b) + + +def multiply(queue, a, b): + queue.put(a * b) \ No newline at end of file diff --git a/test_calc.py b/test_calc.py deleted file mode 100644 index 2b85408..0000000 --- a/test_calc.py +++ /dev/null @@ -1,33 +0,0 @@ -import unittest -from calc import add, subtract, divide, multiply - - -class TestCalc(unittest.TestCase): - def test_add(self): - self.assertEqual(5, add(2, 3)) - self.assertEqual(0, add(2, -2)) - self.assertEqual(-2, add(-5, 3)) - self.assertEqual(2, add(5, -3)) - - def test_subtract(self): - self.assertEqual(-1, subtract(2, 3)) - self.assertEqual(4, subtract(2, -2)) - self.assertEqual(-8, subtract(-5, 3)) - self.assertEqual(2, subtract(5, 3)) - - def test_multiply(self): - self.assertEqual(6, multiply(2, 3)) - self.assertEqual(-4, multiply(2, -2)) - self.assertEqual(-15, multiply(-5, 3)) - self.assertEqual(15, multiply(-5, -3)) - - def test_divide(self): - self.assertEqual(2/3, divide(2, 3)) - self.assertEqual(-1, divide(2, -2)) - self.assertEqual(-5/3, divide(-5, 3)) - self.assertEqual(5/3, divide(-5, -3)) - self.assertRaises(ValueError, divide, 2, 0) - - -if __name__ == "__main__": - unittest.main() diff --git a/test_calc_process.py b/test_calc_process.py new file mode 100644 index 0000000..dd7ac35 --- /dev/null +++ b/test_calc_process.py @@ -0,0 +1,62 @@ +import unittest +import multiprocessing +from calc_process import add, subtract, divide, multiply + + +class TestCalc(unittest.TestCase): + def test_add(self): + queue = multiprocessing.Queue() + + p = multiprocessing.Process( + target=add, + args=(queue, 2, 3), + ) + p.start() + result = queue.get() + p.join() + + self.assertEqual(result, 5) + + def test_subtract(self): + queue = multiprocessing.Queue() + + p = multiprocessing.Process( + target=subtract, + args=(queue, 2, 3), + ) + p.start() + result = queue.get() + p.join() + + self.assertEqual(result, -1) + + def test_multiply(self): + queue = multiprocessing.Queue() + + p = multiprocessing.Process( + target=multiply, + args=(queue, 2, 3), + ) + p.start() + result = queue.get() + p.join() + + self.assertEqual(result, 6) + + def test_divide(self): + queue = multiprocessing.Queue() + + p = multiprocessing.Process( + target=divide, + args=(queue, 2, 3), + ) + p.start() + result = queue.get() + p.join() + + self.assertEqual(result, 2/3) + self.assertRaises(ValueError, divide, [], 2, 0) + + +if __name__ == "__main__": + unittest.main() From 8f8ffb437a395aeac91e0b5fefbf562739c5011f Mon Sep 17 00:00:00 2001 From: Saransh Date: Wed, 13 Jul 2022 15:55:27 +0530 Subject: [PATCH 2/2] flake8 --- calc_process.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/calc_process.py b/calc_process.py index ae0289b..5007fc8 100644 --- a/calc_process.py +++ b/calc_process.py @@ -13,4 +13,4 @@ def divide(queue, a, b): def multiply(queue, a, b): - queue.put(a * b) \ No newline at end of file + queue.put(a * b)