zhongjiajie commented on issue #7901: Remove sql like function in base_hook
URL: https://github.com/apache/airflow/pull/7901#issuecomment-604968747
 
 
   Seem unrelated failed 
   ```sh
   self = <tests.cli.commands.test_task_command.TestCliTasks 
testMethod=test_local_run>
       def test_local_run(self):
           args = self.parser.parse_args([
               'tasks',
               'run',
               'example_python_operator',
               'print_the_context',
               '2018-04-27T08:39:51.298439+00:00',
               '--interactive',
               '--subdir',
               '/root/dags/example_python_operator.py'
           ])
       
           dag = get_dag(args.subdir, args.dag_id)
           reset(dag.dag_id)
       
   >       task_command.task_run(args)
   tests/cli/commands/test_task_command.py:237: 
   _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ 
   airflow/cli/commands/task_command.py:183: in task_run
       _run_task_by_selected_method(args, dag, ti)
   airflow/cli/commands/task_command.py:63: in _run_task_by_selected_method
       _run_task_by_executor(args, dag, ti)
   airflow/cli/commands/task_command.py:99: in _run_task_by_executor
       executor.end()
   airflow/executors/local_executor.py:326: in end
       self.impl.end()
   airflow/executors/local_executor.py:285: in end
       self.queue.join()
   <string>:2: in join
       ???
   /usr/local/lib/python3.6/multiprocessing/managers.py:757: in _callmethod
       kind, result = conn.recv()
   /usr/local/lib/python3.6/multiprocessing/connection.py:250: in recv
       buf = self._recv_bytes()
   /usr/local/lib/python3.6/multiprocessing/connection.py:407: in _recv_bytes
       buf = self._recv(4)
   _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ 
   self = <multiprocessing.connection.Connection object at 0x7f08c54e6c18>
   size = 4, read = <built-in function read>
       def _recv(self, size, read=_read):
           buf = io.BytesIO()
           handle = self._handle
           remaining = size
           while remaining > 0:
               chunk = read(handle, remaining)
               n = len(chunk)
               if n == 0:
                   if remaining == size:
   >                   raise EOFError
   E                   EOFError
   /usr/local/lib/python3.6/multiprocessing/connection.py:383: EOFError
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to