Class Input

shared/database/input.py:11–400

class Input(Base):
    __tablename__ = 'input'

    id = Column(Integer, primary_key = True)
    created_time = Column(DateTime, default = datetime.datetime.utcnow)

    time_completed = Column(DateTime)
    time_loaded_video = Column(DateTime)

    # We assume this includes upload
    time_video_write_finished = Column(DateTime)

    # Frames can start processing as this happens
    # But it's still an "end point" to measure
    # ie we could look at other options to speed that up.
    time_pushed_all_frames_to_queue = Column(DateTime)

    # Yes some work to update this
    # BUT this is probably a better measure for more closely tracking
    # if the process crashes so worth it.
    time_updated = Column(DateTime, onupdate = datetime.datetime.utcnow)

    time_last_attempted = Column(Integer)

    # ["copy_file", "update", "update_with_existing", ""]
    mode = Column(String)

    url = Column(String())
    media_type = Column(String())  # image, frame, video, csv

    type = Column(String())  # ["from_url", "from_video_split", "from_blob_path"]

    allow_csv = Column(Boolean())

    allow_duplicates = Column(Boolean(), default = False)

    processing_deferred = Column(Boolean(), default = False)

    status = Column(String(), default = "init")
    status_text = Column(String())

    offset_in_seconds = Column(Integer)
    percent_complete = Column(Float, default = 0.0)

    description = Column(String())
    text_data = Column(String())
    size = Column(Integer)

    archived = Column(Boolean, default = False)

    auto_correct_instances_from_image_metadata = Column(Boolean, default = False)

    raw_data_blob_path = Column(String())
    # video_processed_blob_path = Column(String())

    resumable_url = Column(String())

    # For AWS S3 Uploads