Dumper

Complexity

Total Complexity

38

Size/Duplication

Total Lines	149
Duplicated Lines	0 %

13 Methods

Rating	Name	Duplication	Size	Complexity
A	_get_file_name()	0	5	1
A	_write_to_disk()	0	17	4
A	_create_date_folder()	0	10	3
A	_get_date_folder()	0	2	1
A	_write_marker_to_db()	0	17	3
A	wait()	0	2	1
A	start()	0	4	2
A	stop()	0	3	1
A	_write_batch_to_disk()	0	3	1
B	_get_batch()	0	16	5
B	_update_marker()	0	15	6
A	_flush()	0	9	4
B	__init__()	0	32	6

# -*- coding: utf-8 -*-
# Licensed to the StackStorm, Inc ('StackStorm') under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import os

from pip.req import parse_requirements

__all__ = [
    'fetch_requirements',
    'apply_vagrant_workaround'
]


def fetch_requirements(requirements_file_path):
    """
    Return a list of requirements and links by parsing the provided requirements file.
    """
    links = []
    reqs = []
    for req in parse_requirements(requirements_file_path, session=False):
        if req.link:
            links.append(str(req.link))
        reqs.append(str(req.req))
    return (reqs, links)


def apply_vagrant_workaround():
    """
    Function which detects if the script is being executed inside vagrant and if it is, it deletes
    "os.link" attribute.
    Note: Without this workaround, setup.py sdist will fail when running inside a shared directory
    (nfs / virtualbox shared folders).
    """
    if os.environ.get('USER', None) == 'vagrant':
        del os.link